Reference documentation and code samples for the Dataflow V1beta3 API class Google::Cloud::Dataflow::V1beta3::ComputationTopology.
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
- (::Array<::Google::Cloud::Dataflow::V1beta3::StreamLocation>) — The inputs to the computation.
#inputs=
def inputs=(value) -> ::Array<::Google::Cloud::Dataflow::V1beta3::StreamLocation>
Parameter
- value (::Array<::Google::Cloud::Dataflow::V1beta3::StreamLocation>) — The inputs to the computation.
Returns
- (::Array<::Google::Cloud::Dataflow::V1beta3::StreamLocation>) — The inputs to the computation.
#key_ranges
def key_ranges() -> ::Array<::Google::Cloud::Dataflow::V1beta3::KeyRangeLocation>
Returns
- (::Array<::Google::Cloud::Dataflow::V1beta3::KeyRangeLocation>) — The key ranges processed by the computation.
#key_ranges=
def key_ranges=(value) -> ::Array<::Google::Cloud::Dataflow::V1beta3::KeyRangeLocation>
Parameter
- value (::Array<::Google::Cloud::Dataflow::V1beta3::KeyRangeLocation>) — The key ranges processed by the computation.
Returns
- (::Array<::Google::Cloud::Dataflow::V1beta3::KeyRangeLocation>) — The key ranges processed by the computation.
#outputs
def outputs() -> ::Array<::Google::Cloud::Dataflow::V1beta3::StreamLocation>
Returns
- (::Array<::Google::Cloud::Dataflow::V1beta3::StreamLocation>) — The outputs from the computation.
#outputs=
def outputs=(value) -> ::Array<::Google::Cloud::Dataflow::V1beta3::StreamLocation>
Parameter
- value (::Array<::Google::Cloud::Dataflow::V1beta3::StreamLocation>) — The outputs from the computation.
Returns
- (::Array<::Google::Cloud::Dataflow::V1beta3::StreamLocation>) — The outputs from the computation.
#state_families
def state_families() -> ::Array<::Google::Cloud::Dataflow::V1beta3::StateFamilyConfig>
Returns
- (::Array<::Google::Cloud::Dataflow::V1beta3::StateFamilyConfig>) — The state family values.
#state_families=
def state_families=(value) -> ::Array<::Google::Cloud::Dataflow::V1beta3::StateFamilyConfig>
Parameter
- value (::Array<::Google::Cloud::Dataflow::V1beta3::StateFamilyConfig>) — The state family values.
Returns
- (::Array<::Google::Cloud::Dataflow::V1beta3::StateFamilyConfig>) — The state family values.
#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.