public abstract static class DataflowWorker.WorkUnitClient extends Object
| Constructor and Description |
|---|
WorkUnitClient() |
| 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. |
public abstract com.google.api.services.dataflow.model.WorkItem getWorkItem()
throws IOException
IOExceptionpublic abstract com.google.api.services.dataflow.model.WorkItemServiceState reportWorkItemStatus(com.google.api.services.dataflow.model.WorkItemStatus workItemStatus)
throws IOException
WorkItemStatus for an assigned WorkItem.workItemStatus - the status to reportWorkItemServiceState (e.g. a new stop position)IOException