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

Class DataflowWorker.WorkUnitClient

java.lang.Object

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

Enclosing class:

DataflowWorker

public abstract static class DataflowWorker.WorkUnitClient
extends Object

Abstract base class describing a client for WorkItem work units.

Constructor Summary

Constructors

Constructor and Description
WorkUnitClient()

Method Summary

Modifier and Type	Method and Description
abstract com.google.api.services.dataflow.model.WorkItem	getWorkItem() Returns a new WorkItem unit for this Worker to work on or null if no work item is available.
abstract com.google.api.services.dataflow.model.WorkItemServiceState	reportWorkItemStatus(com.google.api.services.dataflow.model.WorkItemStatus workItemStatus) Reports a WorkItemStatus for an assigned WorkItem.

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkUnitClient

public WorkUnitClient()

Method Detail

getWorkItem

public abstract com.google.api.services.dataflow.model.WorkItem getWorkItem()
                                                                     throws IOException

Returns a new WorkItem unit for this Worker to work on or null if no work item is available.

Throws:

IOException

reportWorkItemStatus

public abstract com.google.api.services.dataflow.model.WorkItemServiceState reportWorkItemStatus(com.google.api.services.dataflow.model.WorkItemStatus workItemStatus)
                                                                                          throws IOException

Reports a WorkItemStatus for an assigned WorkItem.

Parameters:

workItemStatus - the status to report

Returns:

a WorkItemServiceState (e.g. a new stop position)

Throws:

IOException