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

Class DataflowWorkProgressUpdater

java.lang.Object

com.google.cloud.dataflow.sdk.util.common.worker.WorkProgressUpdater

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

@NotThreadSafe
public class DataflowWorkProgressUpdater
extends WorkProgressUpdater

DataflowWorkProgressUpdater implements the WorkProgressUpdater interface for the Cloud Dataflow system.

Field Summary

Fields inherited from class com.google.cloud.dataflow.sdk.util.common.worker.WorkProgressUpdater

DEFAULT_LEASE_DURATION_MILLIS, dynamicSplitResultToReport, progressReportIntervalMs, requestedLeaseDurationMs, worker

Constructor Summary

Constructors

Constructor and Description
DataflowWorkProgressUpdater(com.google.api.services.dataflow.model.WorkItem workItem, WorkExecutor worker, DataflowWorker.WorkUnitClient workUnitClient, DataflowWorkerHarnessOptions options)

Method Summary

Modifier and Type	Method and Description
protected long	getWorkUnitLeaseExpirationTimestamp() Returns the current work item's lease expiration timestamp.
protected long	getWorkUnitSuggestedReportingInterval() Returns the current work item's suggested progress reporting interval.
protected void	reportProgressHelper() Reports the current work progress to the worker service.
protected String	workString() Returns a string representation of the work item whose progress is being updated, for use in logging messages.

Methods inherited from class com.google.cloud.dataflow.sdk.util.common.worker.WorkProgressUpdater

getDynamicSplitResultToReport, getLeaseRenewalLatencyMargin, getMaxReportingInterval, getMinReportingInterval, leaseRemainingTime, nextProgressReportInterval, startReportingProgress, stopReportingProgress

Methods inherited from class java.lang.Object

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

Constructor Detail

DataflowWorkProgressUpdater

public DataflowWorkProgressUpdater(com.google.api.services.dataflow.model.WorkItem workItem,
                                   WorkExecutor worker,
                                   DataflowWorker.WorkUnitClient workUnitClient,
                                   DataflowWorkerHarnessOptions options)

Method Detail

workString

protected String workString()

Description copied from class: WorkProgressUpdater

Returns a string representation of the work item whose progress is being updated, for use in logging messages.

Specified by:

workString in class WorkProgressUpdater

getWorkUnitLeaseExpirationTimestamp

protected long getWorkUnitLeaseExpirationTimestamp()

Description copied from class: WorkProgressUpdater

Returns the current work item's lease expiration timestamp.

Specified by:

getWorkUnitLeaseExpirationTimestamp in class WorkProgressUpdater

getWorkUnitSuggestedReportingInterval

protected long getWorkUnitSuggestedReportingInterval()

Description copied from class: WorkProgressUpdater

Returns the current work item's suggested progress reporting interval.

Overrides:

getWorkUnitSuggestedReportingInterval in class WorkProgressUpdater

reportProgressHelper

protected void reportProgressHelper()
                             throws Exception

Description copied from class: WorkProgressUpdater

Reports the current work progress to the worker service.

Specified by:

reportProgressHelper in class WorkProgressUpdater

Throws:

Exception