Description of the composing transforms, names/ids, and input/outputs of a stage of execution. Some composing transforms and sources may have been generated by the Dataflow service during execution planning.
Inherits
- Object
Extended By
- Google::Protobuf::MessageExts::ClassMethods
Includes
- Google::Protobuf::MessageExts
Methods
#component_source
def component_source() -> ::Array<::Google::Cloud::Dataflow::V1beta3::ExecutionStageSummary::ComponentSource>
Returns
- (::Array<::Google::Cloud::Dataflow::V1beta3::ExecutionStageSummary::ComponentSource>) — Collections produced and consumed by component transforms of this stage.
#component_source=
def component_source=(value) -> ::Array<::Google::Cloud::Dataflow::V1beta3::ExecutionStageSummary::ComponentSource>
Parameter
- value (::Array<::Google::Cloud::Dataflow::V1beta3::ExecutionStageSummary::ComponentSource>) — Collections produced and consumed by component transforms of this stage.
Returns
- (::Array<::Google::Cloud::Dataflow::V1beta3::ExecutionStageSummary::ComponentSource>) — Collections produced and consumed by component transforms of this stage.
#component_transform
def component_transform() -> ::Array<::Google::Cloud::Dataflow::V1beta3::ExecutionStageSummary::ComponentTransform>
Returns
- (::Array<::Google::Cloud::Dataflow::V1beta3::ExecutionStageSummary::ComponentTransform>) — Transforms that comprise this execution stage.
#component_transform=
def component_transform=(value) -> ::Array<::Google::Cloud::Dataflow::V1beta3::ExecutionStageSummary::ComponentTransform>
Parameter
- value (::Array<::Google::Cloud::Dataflow::V1beta3::ExecutionStageSummary::ComponentTransform>) — Transforms that comprise this execution stage.
Returns
- (::Array<::Google::Cloud::Dataflow::V1beta3::ExecutionStageSummary::ComponentTransform>) — Transforms that comprise this execution stage.
#id
def id() -> ::String
Returns
- (::String) — Dataflow service generated id for this stage.
#id=
def id=(value) -> ::String
Parameter
- value (::String) — Dataflow service generated id for this stage.
Returns
- (::String) — Dataflow service generated id for this stage.
#input_source
def input_source() -> ::Array<::Google::Cloud::Dataflow::V1beta3::ExecutionStageSummary::StageSource>
Returns
- (::Array<::Google::Cloud::Dataflow::V1beta3::ExecutionStageSummary::StageSource>) — Input sources for this stage.
#input_source=
def input_source=(value) -> ::Array<::Google::Cloud::Dataflow::V1beta3::ExecutionStageSummary::StageSource>
Parameter
- value (::Array<::Google::Cloud::Dataflow::V1beta3::ExecutionStageSummary::StageSource>) — Input sources for this stage.
Returns
- (::Array<::Google::Cloud::Dataflow::V1beta3::ExecutionStageSummary::StageSource>) — Input sources for this stage.
#kind
def kind() -> ::Google::Cloud::Dataflow::V1beta3::KindType
Returns
- (::Google::Cloud::Dataflow::V1beta3::KindType) — Type of transform this stage is executing.
#kind=
def kind=(value) -> ::Google::Cloud::Dataflow::V1beta3::KindType
Parameter
- value (::Google::Cloud::Dataflow::V1beta3::KindType) — Type of transform this stage is executing.
Returns
- (::Google::Cloud::Dataflow::V1beta3::KindType) — Type of transform this stage is executing.
#name
def name() -> ::String
Returns
- (::String) — Dataflow service generated name for this stage.
#name=
def name=(value) -> ::String
Parameter
- value (::String) — Dataflow service generated name for this stage.
Returns
- (::String) — Dataflow service generated name for this stage.
#output_source
def output_source() -> ::Array<::Google::Cloud::Dataflow::V1beta3::ExecutionStageSummary::StageSource>
Returns
- (::Array<::Google::Cloud::Dataflow::V1beta3::ExecutionStageSummary::StageSource>) — Output sources for this stage.
#output_source=
def output_source=(value) -> ::Array<::Google::Cloud::Dataflow::V1beta3::ExecutionStageSummary::StageSource>
Parameter
- value (::Array<::Google::Cloud::Dataflow::V1beta3::ExecutionStageSummary::StageSource>) — Output sources for this stage.
Returns
- (::Array<::Google::Cloud::Dataflow::V1beta3::ExecutionStageSummary::StageSource>) — Output sources for this stage.
#prerequisite_stage
def prerequisite_stage() -> ::Array<::String>
Returns
- (::Array<::String>) — Other stages that must complete before this stage can run.
#prerequisite_stage=
def prerequisite_stage=(value) -> ::Array<::String>
Parameter
- value (::Array<::String>) — Other stages that must complete before this stage can run.
Returns
- (::Array<::String>) — Other stages that must complete before this stage can run.