Dataflow V1beta3 API - Class Google::Cloud::Dataflow::V1beta3::TopologyConfig (v0.10.0)

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

#computations=

def computations=(value) -> ::Array<::Google::Cloud::Dataflow::V1beta3::ComputationTopology>
Parameter
Returns

#data_disk_assignments

def data_disk_assignments() -> ::Array<::Google::Cloud::Dataflow::V1beta3::DataDiskAssignment>
Returns

#data_disk_assignments=

def data_disk_assignments=(value) -> ::Array<::Google::Cloud::Dataflow::V1beta3::DataDiskAssignment>
Parameter
Returns

#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.