class Google::Apis::DataflowV1b3::TopologyConfig
Global topology of the streaming Dataflow job, including all computations and their sharded locations.
Attributes
The computations associated with a streaming Dataflow job. Corresponds to the JSON property `computations` @return [Array<Google::Apis::DataflowV1b3::ComputationTopology>]
The disks assigned to a streaming Dataflow job. Corresponds to the JSON property `dataDiskAssignments` @return [Array<Google::Apis::DataflowV1b3::DataDiskAssignment>]
The size (in bits) of keys that will be assigned to source messages. Corresponds to the JSON property `forwardingKeyBits` @return [Fixnum]
Version number for persistent state. Corresponds to the JSON property `persistentStateVersion` @return [Fixnum]
Maps user stage names to stable computation names. Corresponds to the JSON property `userStageToComputationNameMap` @return [Hash<String,String>]
Public Class Methods
# File lib/google/apis/dataflow_v1b3/classes.rb, line 5707 def initialize(**args) update!(**args) end
Public Instance Methods
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