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

Class DataflowWorker

java.lang.Object

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

public class DataflowWorker
extends Object

This is a semi-abstract harness for executing WorkItem tasks in Java workers. Concrete implementations need to implement a WorkUnitClient.

DataflowWorker presents one public interface, getAndPerformWork(), which uses the WorkUnitClient to get work, execute it, and update the work.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DataflowWorker.WorkUnitClient Abstract base class describing a client for WorkItem work units.

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_STATUS_PORT

Constructor Summary

Constructors

Constructor and Description
DataflowWorker(DataflowWorker.WorkUnitClient workUnitClient, DataflowWorkerHarnessOptions options)

Method Summary

Modifier and Type	Method and Description
boolean	getAndPerformWork() Gets WorkItem and performs it; returns true if work was successfully completed.
void	runStatusServer(int statusPort) Runs the status server to report worker health on the specified port.

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_STATUS_PORT

public static final int DEFAULT_STATUS_PORT

See Also:

Constant Field Values

Constructor Detail

DataflowWorker

public DataflowWorker(DataflowWorker.WorkUnitClient workUnitClient,
                      DataflowWorkerHarnessOptions options)

Method Detail

getAndPerformWork

public boolean getAndPerformWork()
                          throws IOException

Gets WorkItem and performs it; returns true if work was successfully completed.

getAndPerformWork may throw if there is a failure of the WorkUnitClient.

Throws:

IOException

runStatusServer

public void runStatusServer(int statusPort)

Runs the status server to report worker health on the specified port.