com.google.cloud.dataflow.sdk.runners.worker

Class DataflowWorkerHarness

java.lang.Object

com.google.cloud.dataflow.sdk.runners.worker.DataflowWorkerHarness

public class DataflowWorkerHarness
extends Object

This is a harness for executing WorkItem tasks in Java workers.

The worker fetches WorkItem units from the Dataflow Service. When the work is complete, the program sends results via the worker service API.

Returns status code 0 on successful completion, 1 on any uncaught failures.

TODO: add support for VM initialization via config. During initialization, we should take a configuration that specifies an initialization function, allowing user code to run on VM startup.

Constructor Summary

Constructors

Constructor and Description
DataflowWorkerHarness()

Method Summary

Modifier and Type	Method and Description
static void	main(String[] args) Fetches and processes work units from the Dataflow service.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DataflowWorkerHarness

public DataflowWorkerHarness()

Method Detail

main

public static void main(String[] args)
                 throws Exception

Fetches and processes work units from the Dataflow service.

Throws:

Exception