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

Version 0.3.0

• 0.9.0 (latest)
• 0.8.2
• 0.7.0
• 0.6.0
• 0.5.0
• 0.4.0
• 0.3.0
• 0.2.0
• 0.1.4

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.