Reference documentation and code samples for the Dataflow V1beta3 API class Google::Cloud::Dataflow::V1beta3::TopologyConfig.
Global topology of the streaming Dataflow job, including all computations and their sharded locations.
Inherits
- Object
Extended By
- Google::Protobuf::MessageExts::ClassMethods
Includes
- Google::Protobuf::MessageExts
Methods
#computations
def computations() -> ::Array<::Google::Cloud::Dataflow::V1beta3::ComputationTopology>
Returns
- (::Array<::Google::Cloud::Dataflow::V1beta3::ComputationTopology>) — The computations associated with a streaming Dataflow job.
#computations=
def computations=(value) -> ::Array<::Google::Cloud::Dataflow::V1beta3::ComputationTopology>
Parameter
- value (::Array<::Google::Cloud::Dataflow::V1beta3::ComputationTopology>) — The computations associated with a streaming Dataflow job.
Returns
- (::Array<::Google::Cloud::Dataflow::V1beta3::ComputationTopology>) — The computations associated with a streaming Dataflow job.
#data_disk_assignments
def data_disk_assignments() -> ::Array<::Google::Cloud::Dataflow::V1beta3::DataDiskAssignment>
Returns
- (::Array<::Google::Cloud::Dataflow::V1beta3::DataDiskAssignment>) — The disks assigned to a streaming Dataflow job.
#data_disk_assignments=
def data_disk_assignments=(value) -> ::Array<::Google::Cloud::Dataflow::V1beta3::DataDiskAssignment>
Parameter
- value (::Array<::Google::Cloud::Dataflow::V1beta3::DataDiskAssignment>) — The disks assigned to a streaming Dataflow job.
Returns
- (::Array<::Google::Cloud::Dataflow::V1beta3::DataDiskAssignment>) — The disks assigned to a streaming Dataflow job.
#forwarding_key_bits
def forwarding_key_bits() -> ::Integer
Returns
- (::Integer) — The size (in bits) of keys that will be assigned to source messages.
#forwarding_key_bits=
def forwarding_key_bits=(value) -> ::Integer
Parameter
- value (::Integer) — The size (in bits) of keys that will be assigned to source messages.
Returns
- (::Integer) — The size (in bits) of keys that will be assigned to source messages.
#persistent_state_version
def persistent_state_version() -> ::Integer
Returns
- (::Integer) — Version number for persistent state.
#persistent_state_version=
def persistent_state_version=(value) -> ::Integer
Parameter
- value (::Integer) — Version number for persistent state.
Returns
- (::Integer) — Version number for persistent state.
#user_stage_to_computation_name_map
def user_stage_to_computation_name_map() -> ::Google::Protobuf::Map{::String => ::String}
Returns
- (::Google::Protobuf::Map{::String => ::String}) — Maps user stage names to stable computation names.
#user_stage_to_computation_name_map=
def user_stage_to_computation_name_map=(value) -> ::Google::Protobuf::Map{::String => ::String}
Parameter
- value (::Google::Protobuf::Map{::String => ::String}) — Maps user stage names to stable computation names.
Returns
- (::Google::Protobuf::Map{::String => ::String}) — Maps user stage names to stable computation names.