class Google::Apis::DataflowV1b3::StreamingSetupTask
A task which initializes part of a streaming Dataflow job.
Attributes
The user has requested drain. Corresponds to the JSON property `drain` @return [Boolean]
The user has requested drain. Corresponds to the JSON property `drain` @return [Boolean]
The TCP port on which the worker should listen for messages from other streaming computation workers. Corresponds to the JSON property `receiveWorkPort` @return [Fixnum]
Streaming appliance snapshot configuration. Corresponds to the JSON property `snapshotConfig` @return [Google::Apis::DataflowV1b3::StreamingApplianceSnapshotConfig]
Global topology of the streaming Dataflow job, including all computations and their sharded locations. Corresponds to the JSON property `streamingComputationTopology` @return [Google::Apis::DataflowV1b3::TopologyConfig]
The TCP port used by the worker to communicate with the Dataflow worker harness. Corresponds to the JSON property `workerHarnessPort` @return [Fixnum]
Public Class Methods
# File lib/google/apis/dataflow_v1b3/classes.rb, line 5392 def initialize(**args) update!(**args) end
Public Instance Methods
Update properties of this object
# File lib/google/apis/dataflow_v1b3/classes.rb, line 5397 def update!(**args) @drain = args[:drain] if args.key?(:drain) @receive_work_port = args[:receive_work_port] if args.key?(:receive_work_port) @snapshot_config = args[:snapshot_config] if args.key?(:snapshot_config) @streaming_computation_topology = args[:streaming_computation_topology] if args.key?(:streaming_computation_topology) @worker_harness_port = args[:worker_harness_port] if args.key?(:worker_harness_port) end