Class ExecutionStageSummary (0.50.0)

public final class ExecutionStageSummary extends GeneratedMessageV3 implements ExecutionStageSummaryOrBuilder

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.

Protobuf type google.dataflow.v1beta3.ExecutionStageSummary

Static Fields

COMPONENT_SOURCE_FIELD_NUMBER

public static final int COMPONENT_SOURCE_FIELD_NUMBER
Field Value
Type Description
int

COMPONENT_TRANSFORM_FIELD_NUMBER

public static final int COMPONENT_TRANSFORM_FIELD_NUMBER
Field Value
Type Description
int

ID_FIELD_NUMBER

public static final int ID_FIELD_NUMBER
Field Value
Type Description
int

INPUT_SOURCE_FIELD_NUMBER

public static final int INPUT_SOURCE_FIELD_NUMBER
Field Value
Type Description
int

KIND_FIELD_NUMBER

public static final int KIND_FIELD_NUMBER
Field Value
Type Description
int

NAME_FIELD_NUMBER

public static final int NAME_FIELD_NUMBER
Field Value
Type Description
int

OUTPUT_SOURCE_FIELD_NUMBER

public static final int OUTPUT_SOURCE_FIELD_NUMBER
Field Value
Type Description
int

PREREQUISITE_STAGE_FIELD_NUMBER

public static final int PREREQUISITE_STAGE_FIELD_NUMBER
Field Value
Type Description
int

Static Methods

getDefaultInstance()

public static ExecutionStageSummary getDefaultInstance()
Returns
Type Description
ExecutionStageSummary

getDescriptor()

public static final Descriptors.Descriptor getDescriptor()
Returns
Type Description
Descriptor

newBuilder()

public static ExecutionStageSummary.Builder newBuilder()
Returns
Type Description
ExecutionStageSummary.Builder

newBuilder(ExecutionStageSummary prototype)

public static ExecutionStageSummary.Builder newBuilder(ExecutionStageSummary prototype)
Parameter
Name Description
prototype ExecutionStageSummary
Returns
Type Description
ExecutionStageSummary.Builder

parseDelimitedFrom(InputStream input)

public static ExecutionStageSummary parseDelimitedFrom(InputStream input)
Parameter
Name Description
input InputStream
Returns
Type Description
ExecutionStageSummary
Exceptions
Type Description
IOException

parseDelimitedFrom(InputStream input, ExtensionRegistryLite extensionRegistry)

public static ExecutionStageSummary parseDelimitedFrom(InputStream input, ExtensionRegistryLite extensionRegistry)
Parameters
Name Description
input InputStream
extensionRegistry ExtensionRegistryLite
Returns
Type Description
ExecutionStageSummary
Exceptions
Type Description
IOException

parseFrom(byte[] data)

public static ExecutionStageSummary parseFrom(byte[] data)
Parameter
Name Description
data byte[]
Returns
Type Description
ExecutionStageSummary
Exceptions
Type Description
InvalidProtocolBufferException

parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)

public static ExecutionStageSummary parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)
Parameters
Name Description
data byte[]
extensionRegistry ExtensionRegistryLite
Returns
Type Description
ExecutionStageSummary
Exceptions
Type Description
InvalidProtocolBufferException

parseFrom(ByteString data)

public static ExecutionStageSummary parseFrom(ByteString data)
Parameter
Name Description
data ByteString
Returns
Type Description
ExecutionStageSummary
Exceptions
Type Description
InvalidProtocolBufferException

parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)

public static ExecutionStageSummary parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)
Parameters
Name Description
data ByteString
extensionRegistry ExtensionRegistryLite
Returns
Type Description
ExecutionStageSummary
Exceptions
Type Description
InvalidProtocolBufferException

parseFrom(CodedInputStream input)

public static ExecutionStageSummary parseFrom(CodedInputStream input)
Parameter
Name Description
input CodedInputStream
Returns
Type Description
ExecutionStageSummary
Exceptions
Type Description
IOException

parseFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)

public static ExecutionStageSummary parseFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)
Parameters
Name Description
input CodedInputStream
extensionRegistry ExtensionRegistryLite
Returns
Type Description
ExecutionStageSummary
Exceptions
Type Description
IOException

parseFrom(InputStream input)

public static ExecutionStageSummary parseFrom(InputStream input)
Parameter
Name Description
input InputStream
Returns
Type Description
ExecutionStageSummary
Exceptions
Type Description
IOException

parseFrom(InputStream input, ExtensionRegistryLite extensionRegistry)

public static ExecutionStageSummary parseFrom(InputStream input, ExtensionRegistryLite extensionRegistry)
Parameters
Name Description
input InputStream
extensionRegistry ExtensionRegistryLite
Returns
Type Description
ExecutionStageSummary
Exceptions
Type Description
IOException

parseFrom(ByteBuffer data)

public static ExecutionStageSummary parseFrom(ByteBuffer data)
Parameter
Name Description
data ByteBuffer
Returns
Type Description
ExecutionStageSummary
Exceptions
Type Description
InvalidProtocolBufferException

parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)

public static ExecutionStageSummary parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)
Parameters
Name Description
data ByteBuffer
extensionRegistry ExtensionRegistryLite
Returns
Type Description
ExecutionStageSummary
Exceptions
Type Description
InvalidProtocolBufferException

parser()

public static Parser<ExecutionStageSummary> parser()
Returns
Type Description
Parser<ExecutionStageSummary>

Methods

equals(Object obj)

public boolean equals(Object obj)
Parameter
Name Description
obj Object
Returns
Type Description
boolean
Overrides

getComponentSource(int index)

public ExecutionStageSummary.ComponentSource getComponentSource(int index)

Collections produced and consumed by component transforms of this stage.

repeated .google.dataflow.v1beta3.ExecutionStageSummary.ComponentSource component_source = 7;

Parameter
Name Description
index int
Returns
Type Description
ExecutionStageSummary.ComponentSource

getComponentSourceCount()

public int getComponentSourceCount()

Collections produced and consumed by component transforms of this stage.

repeated .google.dataflow.v1beta3.ExecutionStageSummary.ComponentSource component_source = 7;

Returns
Type Description
int

getComponentSourceList()

public List<ExecutionStageSummary.ComponentSource> getComponentSourceList()

Collections produced and consumed by component transforms of this stage.

repeated .google.dataflow.v1beta3.ExecutionStageSummary.ComponentSource component_source = 7;

Returns
Type Description
List<ComponentSource>

getComponentSourceOrBuilder(int index)

public ExecutionStageSummary.ComponentSourceOrBuilder getComponentSourceOrBuilder(int index)

Collections produced and consumed by component transforms of this stage.

repeated .google.dataflow.v1beta3.ExecutionStageSummary.ComponentSource component_source = 7;

Parameter
Name Description
index int
Returns
Type Description
ExecutionStageSummary.ComponentSourceOrBuilder

getComponentSourceOrBuilderList()

public List<? extends ExecutionStageSummary.ComponentSourceOrBuilder> getComponentSourceOrBuilderList()

Collections produced and consumed by component transforms of this stage.

repeated .google.dataflow.v1beta3.ExecutionStageSummary.ComponentSource component_source = 7;

Returns
Type Description
List<? extends com.google.dataflow.v1beta3.ExecutionStageSummary.ComponentSourceOrBuilder>

getComponentTransform(int index)

public ExecutionStageSummary.ComponentTransform getComponentTransform(int index)

Transforms that comprise this execution stage.

repeated .google.dataflow.v1beta3.ExecutionStageSummary.ComponentTransform component_transform = 6;

Parameter
Name Description
index int
Returns
Type Description
ExecutionStageSummary.ComponentTransform

getComponentTransformCount()

public int getComponentTransformCount()

Transforms that comprise this execution stage.

repeated .google.dataflow.v1beta3.ExecutionStageSummary.ComponentTransform component_transform = 6;

Returns
Type Description
int

getComponentTransformList()

public List<ExecutionStageSummary.ComponentTransform> getComponentTransformList()

Transforms that comprise this execution stage.

repeated .google.dataflow.v1beta3.ExecutionStageSummary.ComponentTransform component_transform = 6;

Returns
Type Description
List<ComponentTransform>

getComponentTransformOrBuilder(int index)

public ExecutionStageSummary.ComponentTransformOrBuilder getComponentTransformOrBuilder(int index)

Transforms that comprise this execution stage.

repeated .google.dataflow.v1beta3.ExecutionStageSummary.ComponentTransform component_transform = 6;

Parameter
Name Description
index int
Returns
Type Description
ExecutionStageSummary.ComponentTransformOrBuilder

getComponentTransformOrBuilderList()

public List<? extends ExecutionStageSummary.ComponentTransformOrBuilder> getComponentTransformOrBuilderList()

Transforms that comprise this execution stage.

repeated .google.dataflow.v1beta3.ExecutionStageSummary.ComponentTransform component_transform = 6;

Returns
Type Description
List<? extends com.google.dataflow.v1beta3.ExecutionStageSummary.ComponentTransformOrBuilder>

getDefaultInstanceForType()

public ExecutionStageSummary getDefaultInstanceForType()
Returns
Type Description
ExecutionStageSummary

getId()

public String getId()

Dataflow service generated id for this stage.

string id = 2;

Returns
Type Description
String

The id.

getIdBytes()

public ByteString getIdBytes()

Dataflow service generated id for this stage.

string id = 2;

Returns
Type Description
ByteString

The bytes for id.

getInputSource(int index)

public ExecutionStageSummary.StageSource getInputSource(int index)

Input sources for this stage.

repeated .google.dataflow.v1beta3.ExecutionStageSummary.StageSource input_source = 4;

Parameter
Name Description
index int
Returns
Type Description
ExecutionStageSummary.StageSource

getInputSourceCount()

public int getInputSourceCount()

Input sources for this stage.

repeated .google.dataflow.v1beta3.ExecutionStageSummary.StageSource input_source = 4;

Returns
Type Description
int

getInputSourceList()

public List<ExecutionStageSummary.StageSource> getInputSourceList()

Input sources for this stage.

repeated .google.dataflow.v1beta3.ExecutionStageSummary.StageSource input_source = 4;

Returns
Type Description
List<StageSource>

getInputSourceOrBuilder(int index)

public ExecutionStageSummary.StageSourceOrBuilder getInputSourceOrBuilder(int index)

Input sources for this stage.

repeated .google.dataflow.v1beta3.ExecutionStageSummary.StageSource input_source = 4;

Parameter
Name Description
index int
Returns
Type Description
ExecutionStageSummary.StageSourceOrBuilder

getInputSourceOrBuilderList()

public List<? extends ExecutionStageSummary.StageSourceOrBuilder> getInputSourceOrBuilderList()

Input sources for this stage.

repeated .google.dataflow.v1beta3.ExecutionStageSummary.StageSource input_source = 4;

Returns
Type Description
List<? extends com.google.dataflow.v1beta3.ExecutionStageSummary.StageSourceOrBuilder>

getKind()

public KindType getKind()

Type of transform this stage is executing.

.google.dataflow.v1beta3.KindType kind = 3;

Returns
Type Description
KindType

The kind.

getKindValue()

public int getKindValue()

Type of transform this stage is executing.

.google.dataflow.v1beta3.KindType kind = 3;

Returns
Type Description
int

The enum numeric value on the wire for kind.

getName()

public String getName()

Dataflow service generated name for this stage.

string name = 1;

Returns
Type Description
String

The name.

getNameBytes()

public ByteString getNameBytes()

Dataflow service generated name for this stage.

string name = 1;

Returns
Type Description
ByteString

The bytes for name.

getOutputSource(int index)

public ExecutionStageSummary.StageSource getOutputSource(int index)

Output sources for this stage.

repeated .google.dataflow.v1beta3.ExecutionStageSummary.StageSource output_source = 5;

Parameter
Name Description
index int
Returns
Type Description
ExecutionStageSummary.StageSource

getOutputSourceCount()

public int getOutputSourceCount()

Output sources for this stage.

repeated .google.dataflow.v1beta3.ExecutionStageSummary.StageSource output_source = 5;

Returns
Type Description
int

getOutputSourceList()

public List<ExecutionStageSummary.StageSource> getOutputSourceList()

Output sources for this stage.

repeated .google.dataflow.v1beta3.ExecutionStageSummary.StageSource output_source = 5;

Returns
Type Description
List<StageSource>

getOutputSourceOrBuilder(int index)

public ExecutionStageSummary.StageSourceOrBuilder getOutputSourceOrBuilder(int index)

Output sources for this stage.

repeated .google.dataflow.v1beta3.ExecutionStageSummary.StageSource output_source = 5;

Parameter
Name Description
index int
Returns
Type Description
ExecutionStageSummary.StageSourceOrBuilder

getOutputSourceOrBuilderList()

public List<? extends ExecutionStageSummary.StageSourceOrBuilder> getOutputSourceOrBuilderList()

Output sources for this stage.

repeated .google.dataflow.v1beta3.ExecutionStageSummary.StageSource output_source = 5;

Returns
Type Description
List<? extends com.google.dataflow.v1beta3.ExecutionStageSummary.StageSourceOrBuilder>

getParserForType()

public Parser<ExecutionStageSummary> getParserForType()
Returns
Type Description
Parser<ExecutionStageSummary>
Overrides

getPrerequisiteStage(int index)

public String getPrerequisiteStage(int index)

Other stages that must complete before this stage can run.

repeated string prerequisite_stage = 8;

Parameter
Name Description
index int

The index of the element to return.

Returns
Type Description
String

The prerequisiteStage at the given index.

getPrerequisiteStageBytes(int index)

public ByteString getPrerequisiteStageBytes(int index)

Other stages that must complete before this stage can run.

repeated string prerequisite_stage = 8;

Parameter
Name Description
index int

The index of the value to return.

Returns
Type Description
ByteString

The bytes of the prerequisiteStage at the given index.

getPrerequisiteStageCount()

public int getPrerequisiteStageCount()

Other stages that must complete before this stage can run.

repeated string prerequisite_stage = 8;

Returns
Type Description
int

The count of prerequisiteStage.

getPrerequisiteStageList()

public ProtocolStringList getPrerequisiteStageList()

Other stages that must complete before this stage can run.

repeated string prerequisite_stage = 8;

Returns
Type Description
ProtocolStringList

A list containing the prerequisiteStage.

getSerializedSize()

public int getSerializedSize()
Returns
Type Description
int
Overrides

hashCode()

public int hashCode()
Returns
Type Description
int
Overrides

internalGetFieldAccessorTable()

protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
Returns
Type Description
FieldAccessorTable
Overrides

isInitialized()

public final boolean isInitialized()
Returns
Type Description
boolean
Overrides

newBuilderForType()

public ExecutionStageSummary.Builder newBuilderForType()
Returns
Type Description
ExecutionStageSummary.Builder

newBuilderForType(GeneratedMessageV3.BuilderParent parent)

protected ExecutionStageSummary.Builder newBuilderForType(GeneratedMessageV3.BuilderParent parent)
Parameter
Name Description
parent BuilderParent
Returns
Type Description
ExecutionStageSummary.Builder
Overrides

newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)

protected Object newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
Parameter
Name Description
unused UnusedPrivateParameter
Returns
Type Description
Object
Overrides

toBuilder()

public ExecutionStageSummary.Builder toBuilder()
Returns
Type Description
ExecutionStageSummary.Builder

writeTo(CodedOutputStream output)

public void writeTo(CodedOutputStream output)
Parameter
Name Description
output CodedOutputStream
Overrides
Exceptions
Type Description
IOException