com.google.api.services.dataflow.model

Class StreamingSetupTask

java.lang.Object

java.util.AbstractMap<java.lang.String,java.lang.Object>

com.google.api.client.util.GenericData

com.google.api.client.json.GenericJson

com.google.api.services.dataflow.model.StreamingSetupTask

All Implemented Interfaces:

java.lang.Cloneable, java.util.Map<java.lang.String,java.lang.Object>

public final class StreamingSetupTask
extends com.google.api.client.json.GenericJson

A task which initializes part of a streaming Dataflow job.

This is the Java data model class that specifies how to parse/serialize into the JSON that is transmitted over HTTP when working with the Google Dataflow API. For a detailed explanation see: https://developers.google.com/api-client-library/java/google-http-java-client/json

Author:

Google, Inc.

Nested Class Summary

Nested classes/interfaces inherited from class com.google.api.client.util.GenericData

com.google.api.client.util.GenericData.Flags

Nested classes/interfaces inherited from class java.util.AbstractMap

java.util.AbstractMap.SimpleEntry<K,V>, java.util.AbstractMap.SimpleImmutableEntry<K,V>

Nested classes/interfaces inherited from interface java.util.Map

java.util.Map.Entry<K,V>

Constructor Summary

Constructors

Constructor and Description
StreamingSetupTask()

Method Summary

Methods

Modifier and Type	Method and Description
StreamingSetupTask	clone()
java.lang.Boolean	getDrain() The user has requested drain.
java.lang.Integer	getReceiveWorkPort() The TCP port on which the worker should listen for messages from other streaming computation workers.
TopologyConfig	getStreamingComputationTopology() The global topology of the streaming Dataflow job.
java.lang.Integer	getWorkerHarnessPort() The TCP port used by the worker to communicate with the Dataflow worker harness.
StreamingSetupTask	set(java.lang.String fieldName, java.lang.Object value)
StreamingSetupTask	setDrain(java.lang.Boolean drain) The user has requested drain.
StreamingSetupTask	setReceiveWorkPort(java.lang.Integer receiveWorkPort) The TCP port on which the worker should listen for messages from other streaming computation workers.
StreamingSetupTask	setStreamingComputationTopology(TopologyConfig streamingComputationTopology) The global topology of the streaming Dataflow job.
StreamingSetupTask	setWorkerHarnessPort(java.lang.Integer workerHarnessPort) The TCP port used by the worker to communicate with the Dataflow worker harness.

Methods inherited from class com.google.api.client.json.GenericJson

getFactory, setFactory, toPrettyString, toString

Methods inherited from class com.google.api.client.util.GenericData

entrySet, get, getClassInfo, getUnknownKeys, put, putAll, remove, setUnknownKeys

Methods inherited from class java.util.AbstractMap

clear, containsKey, containsValue, equals, hashCode, isEmpty, keySet, size, values

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

StreamingSetupTask

public StreamingSetupTask()

Method Detail

getDrain

public java.lang.Boolean getDrain()

The user has requested drain.

Returns:

value or null for none

setDrain

public StreamingSetupTask setDrain(java.lang.Boolean drain)

The user has requested drain.

Parameters:

drain - drain or null for none

getReceiveWorkPort

public java.lang.Integer getReceiveWorkPort()

The TCP port on which the worker should listen for messages from other streaming computation workers.

Returns:

value or null for none

setReceiveWorkPort

public StreamingSetupTask setReceiveWorkPort(java.lang.Integer receiveWorkPort)

The TCP port on which the worker should listen for messages from other streaming computation workers.

Parameters:

receiveWorkPort - receiveWorkPort or null for none

getStreamingComputationTopology

public TopologyConfig getStreamingComputationTopology()

The global topology of the streaming Dataflow job.

Returns:

value or null for none

setStreamingComputationTopology

public StreamingSetupTask setStreamingComputationTopology(TopologyConfig streamingComputationTopology)

The global topology of the streaming Dataflow job.

Parameters:

streamingComputationTopology - streamingComputationTopology or null for none

getWorkerHarnessPort

public java.lang.Integer getWorkerHarnessPort()

The TCP port used by the worker to communicate with the Dataflow worker harness.

Returns:

value or null for none

setWorkerHarnessPort

public StreamingSetupTask setWorkerHarnessPort(java.lang.Integer workerHarnessPort)

The TCP port used by the worker to communicate with the Dataflow worker harness.

Parameters:

workerHarnessPort - workerHarnessPort or null for none

set

public StreamingSetupTask set(java.lang.String fieldName,
                     java.lang.Object value)

Overrides:

set in class com.google.api.client.json.GenericJson

clone

public StreamingSetupTask clone()

Overrides:

clone in class com.google.api.client.json.GenericJson