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

Class StreamingDataflowWorker

java.lang.Object

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

public class StreamingDataflowWorker
extends Object

Implements a Streaming Dataflow worker.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	StreamingDataflowWorker.KeyTokenInvalidException Indicates that the key token was invalid when data was attempted to be fetched.

Constructor Summary

Constructors

Constructor and Description
StreamingDataflowWorker(List<com.google.api.services.dataflow.model.MapTask> mapTasks, WindmillServerStub server, DataflowWorkerHarnessOptions options)

Method Summary

Modifier and Type	Method and Description
protected static boolean	inPushback(Runtime rt)
static boolean	isKeyTokenInvalidException(Throwable t) Returns whether an exception was caused by a StreamingDataflowWorker.KeyTokenInvalidException.
static void	main(String[] args)
void	runStatusServer(int statusPort)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamingDataflowWorker

public StreamingDataflowWorker(List<com.google.api.services.dataflow.model.MapTask> mapTasks,
                               WindmillServerStub server,
                               DataflowWorkerHarnessOptions options)

Method Detail

isKeyTokenInvalidException

public static boolean isKeyTokenInvalidException(Throwable t)

Returns whether an exception was caused by a StreamingDataflowWorker.KeyTokenInvalidException.

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception

start

public void start()

stop

public void stop()

runStatusServer

public void runStatusServer(int statusPort)

inPushback

protected static boolean inPushback(Runtime rt)