class Google::Apis::DataflowV1b3::TopologyConfig

Global topology of the streaming Dataflow job, including all computations and their sharded locations.

Attributes

computations[RW]

The computations associated with a streaming Dataflow job. Corresponds to the JSON property `computations` @return [Array<Google::Apis::DataflowV1b3::ComputationTopology>]

data_disk_assignments[RW]

The disks assigned to a streaming Dataflow job. Corresponds to the JSON property `dataDiskAssignments` @return [Array<Google::Apis::DataflowV1b3::DataDiskAssignment>]

forwarding_key_bits[RW]

The size (in bits) of keys that will be assigned to source messages. Corresponds to the JSON property `forwardingKeyBits` @return [Fixnum]

persistent_state_version[RW]

Version number for persistent state. Corresponds to the JSON property `persistentStateVersion` @return [Fixnum]

user_stage_to_computation_name_map[RW]

Maps user stage names to stable computation names. Corresponds to the JSON property `userStageToComputationNameMap` @return [Hash<String,String>]

Public Class Methods

new(**args) click to toggle source
# File lib/google/apis/dataflow_v1b3/classes.rb, line 5707
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 5712
def update!(**args)
  @computations = args[:computations] if args.key?(:computations)
  @data_disk_assignments = args[:data_disk_assignments] if args.key?(:data_disk_assignments)
  @forwarding_key_bits = args[:forwarding_key_bits] if args.key?(:forwarding_key_bits)
  @persistent_state_version = args[:persistent_state_version] if args.key?(:persistent_state_version)
  @user_stage_to_computation_name_map = args[:user_stage_to_computation_name_map] if args.key?(:user_stage_to_computation_name_map)
end