Class Google::Cloud::Dataflow::V1beta3::ComputationTopology (v0.2.0)

All configuration data for a particular Computation.

Inherits

  • Object

Extended By

  • Google::Protobuf::MessageExts::ClassMethods

Includes

  • Google::Protobuf::MessageExts

Methods

#computation_id

def computation_id() -> ::String
Returns
  • (::String) — The ID of the computation.

#computation_id=

def computation_id=(value) -> ::String
Parameter
  • value (::String) — The ID of the computation.
Returns
  • (::String) — The ID of the computation.

#inputs

def inputs() -> ::Array<::Google::Cloud::Dataflow::V1beta3::StreamLocation>
Returns

#inputs=

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

#key_ranges

def key_ranges() -> ::Array<::Google::Cloud::Dataflow::V1beta3::KeyRangeLocation>
Returns

#key_ranges=

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

#outputs

def outputs() -> ::Array<::Google::Cloud::Dataflow::V1beta3::StreamLocation>
Returns

#outputs=

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

#state_families

def state_families() -> ::Array<::Google::Cloud::Dataflow::V1beta3::StateFamilyConfig>
Returns

#state_families=

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

#system_stage_name

def system_stage_name() -> ::String
Returns
  • (::String) — The system stage name.

#system_stage_name=

def system_stage_name=(value) -> ::String
Parameter
  • value (::String) — The system stage name.
Returns
  • (::String) — The system stage name.