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

Class MetricTrackingWindmillServerStub

java.lang.Object

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

public class MetricTrackingWindmillServerStub
extends Object

Wrapper around a WindmillServerStub that tracks metrics for the number of in-flight requests.

Constructor Summary

Constructors

Constructor and Description
MetricTrackingWindmillServerStub(WindmillServerStub server)

Method Summary

Modifier and Type	Method and Description
com.google.cloud.dataflow.sdk.runners.worker.windmill.Windmill.GetDataResponse	getSideInputData(com.google.cloud.dataflow.sdk.runners.worker.windmill.Windmill.GetDataRequest request)
com.google.cloud.dataflow.sdk.runners.worker.windmill.Windmill.GetDataResponse	getStateData(com.google.cloud.dataflow.sdk.runners.worker.windmill.Windmill.GetDataRequest request)
void	printHtml(PrintWriter writer)
AutoCloseable	sideInput()

Methods inherited from class java.lang.Object

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

Constructor Detail

MetricTrackingWindmillServerStub

public MetricTrackingWindmillServerStub(WindmillServerStub server)

Method Detail

getStateData

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

getSideInputData

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

printHtml

public void printHtml(PrintWriter writer)

sideInput

public AutoCloseable sideInput()