Dataflow V1beta3 API - Class Google::Cloud::Dataflow::V1beta3::TopologyConfig (v0.5.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

(::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.