class Google::Apis::DataflowV1b3::StreamingSetupTask

A task which initializes part of a streaming Dataflow job.

Attributes

drain[RW]

The user has requested drain. Corresponds to the JSON property `drain` @return [Boolean]

drain?[RW]

The user has requested drain. Corresponds to the JSON property `drain` @return [Boolean]

receive_work_port[RW]

The TCP port on which the worker should listen for messages from other streaming computation workers. Corresponds to the JSON property `receiveWorkPort` @return [Fixnum]

snapshot_config[RW]

Streaming appliance snapshot configuration. Corresponds to the JSON property `snapshotConfig` @return [Google::Apis::DataflowV1b3::StreamingApplianceSnapshotConfig]

streaming_computation_topology[RW]

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]

worker_harness_port[RW]

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

new(**args) click to toggle source
# File lib/google/apis/dataflow_v1b3/classes.rb, line 5392
def initialize(**args)
   update!(**args)
end

Public Instance Methods

update!(**args) click to toggle source

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