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

Class WindmillServerStub

java.lang.Object

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

public abstract class WindmillServerStub
extends Object

Stub for communicating with a Windmill server.

Constructor Summary

Constructors

Constructor and Description
WindmillServerStub()

Method Summary

Modifier and Type	Method and Description
abstract com.google.cloud.dataflow.sdk.runners.worker.windmill.Windmill.CommitWorkResponse	commitWork(com.google.cloud.dataflow.sdk.runners.worker.windmill.Windmill.CommitWorkRequest request) Commit the work, issuing any output productions, state modifications etc.
abstract com.google.cloud.dataflow.sdk.runners.worker.windmill.Windmill.GetConfigResponse	getConfig(com.google.cloud.dataflow.sdk.runners.worker.windmill.Windmill.GetConfigRequest request) Get configuration data from the server.
abstract com.google.cloud.dataflow.sdk.runners.worker.windmill.Windmill.GetDataResponse	getData(com.google.cloud.dataflow.sdk.runners.worker.windmill.Windmill.GetDataRequest request) Get addition data such as state needed to process work.
abstract com.google.cloud.dataflow.sdk.runners.worker.windmill.Windmill.GetWorkResponse	getWork(com.google.cloud.dataflow.sdk.runners.worker.windmill.Windmill.GetWorkRequest request) Get a batch of work to process.
abstract com.google.cloud.dataflow.sdk.runners.worker.windmill.Windmill.ReportStatsResponse	reportStats(com.google.cloud.dataflow.sdk.runners.worker.windmill.Windmill.ReportStatsRequest request) Report execution information to the server.

Methods inherited from class java.lang.Object

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

Constructor Detail

WindmillServerStub

public WindmillServerStub()

Method Detail

getWork

public abstract com.google.cloud.dataflow.sdk.runners.worker.windmill.Windmill.GetWorkResponse getWork(com.google.cloud.dataflow.sdk.runners.worker.windmill.Windmill.GetWorkRequest request)

Get a batch of work to process.

getData

public abstract com.google.cloud.dataflow.sdk.runners.worker.windmill.Windmill.GetDataResponse getData(com.google.cloud.dataflow.sdk.runners.worker.windmill.Windmill.GetDataRequest request)

Get addition data such as state needed to process work.

commitWork

public abstract com.google.cloud.dataflow.sdk.runners.worker.windmill.Windmill.CommitWorkResponse commitWork(com.google.cloud.dataflow.sdk.runners.worker.windmill.Windmill.CommitWorkRequest request)

Commit the work, issuing any output productions, state modifications etc.

getConfig

public abstract com.google.cloud.dataflow.sdk.runners.worker.windmill.Windmill.GetConfigResponse getConfig(com.google.cloud.dataflow.sdk.runners.worker.windmill.Windmill.GetConfigRequest request)

Get configuration data from the server.

reportStats

public abstract com.google.cloud.dataflow.sdk.runners.worker.windmill.Windmill.ReportStatsResponse reportStats(com.google.cloud.dataflow.sdk.runners.worker.windmill.Windmill.ReportStatsRequest request)

Report execution information to the server.