Class ExecutionStageSummary (0.31.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
TypeDescription
int

COMPONENT_TRANSFORM_FIELD_NUMBER

public static final int COMPONENT_TRANSFORM_FIELD_NUMBER
Field Value
TypeDescription
int

ID_FIELD_NUMBER

public static final int ID_FIELD_NUMBER
Field Value
TypeDescription
int

INPUT_SOURCE_FIELD_NUMBER

public static final int INPUT_SOURCE_FIELD_NUMBER
Field Value
TypeDescription
int

KIND_FIELD_NUMBER

public static final int KIND_FIELD_NUMBER
Field Value
TypeDescription
int

NAME_FIELD_NUMBER

public static final int NAME_FIELD_NUMBER
Field Value
TypeDescription
int

OUTPUT_SOURCE_FIELD_NUMBER

public static final int OUTPUT_SOURCE_FIELD_NUMBER
Field Value
TypeDescription
int

PREREQUISITE_STAGE_FIELD_NUMBER

public static final int PREREQUISITE_STAGE_FIELD_NUMBER
Field Value
TypeDescription
int

Static Methods

getDefaultInstance()

public static ExecutionStageSummary getDefaultInstance()
Returns
TypeDescription
ExecutionStageSummary

getDescriptor()

public static final Descriptors.Descriptor getDescriptor()
Returns
TypeDescription
Descriptor

newBuilder()

public static ExecutionStageSummary.Builder newBuilder()
Returns
TypeDescription
ExecutionStageSummary.Builder

newBuilder(ExecutionStageSummary prototype)

public static ExecutionStageSummary.Builder newBuilder(ExecutionStageSummary prototype)
Parameter
NameDescription
prototypeExecutionStageSummary
Returns
TypeDescription
ExecutionStageSummary.Builder

parseDelimitedFrom(InputStream input)

public static ExecutionStageSummary parseDelimitedFrom(InputStream input)
Parameter
NameDescription
inputInputStream
Returns
TypeDescription
ExecutionStageSummary
Exceptions
TypeDescription
IOException

parseDelimitedFrom(InputStream input, ExtensionRegistryLite extensionRegistry)

public static ExecutionStageSummary parseDelimitedFrom(InputStream input, ExtensionRegistryLite extensionRegistry)
Parameters
NameDescription
inputInputStream
extensionRegistryExtensionRegistryLite
Returns
TypeDescription
ExecutionStageSummary
Exceptions
TypeDescription
IOException

parseFrom(byte[] data)

public static ExecutionStageSummary parseFrom(byte[] data)
Parameter
NameDescription
databyte[]
Returns
TypeDescription
ExecutionStageSummary
Exceptions
TypeDescription
InvalidProtocolBufferException

parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)

public static ExecutionStageSummary parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)
Parameters
NameDescription
databyte[]
extensionRegistryExtensionRegistryLite
Returns
TypeDescription
ExecutionStageSummary
Exceptions
TypeDescription
InvalidProtocolBufferException

parseFrom(ByteString data)

public static ExecutionStageSummary parseFrom(ByteString data)
Parameter
NameDescription
dataByteString
Returns
TypeDescription
ExecutionStageSummary
Exceptions
TypeDescription
InvalidProtocolBufferException

parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)

public static ExecutionStageSummary parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)
Parameters
NameDescription
dataByteString
extensionRegistryExtensionRegistryLite
Returns
TypeDescription
ExecutionStageSummary
Exceptions
TypeDescription
InvalidProtocolBufferException

parseFrom(CodedInputStream input)

public static ExecutionStageSummary parseFrom(CodedInputStream input)
Parameter
NameDescription
inputCodedInputStream
Returns
TypeDescription
ExecutionStageSummary
Exceptions
TypeDescription
IOException

parseFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)

public static ExecutionStageSummary parseFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)
Parameters
NameDescription
inputCodedInputStream
extensionRegistryExtensionRegistryLite
Returns
TypeDescription
ExecutionStageSummary
Exceptions
TypeDescription
IOException

parseFrom(InputStream input)

public static ExecutionStageSummary parseFrom(InputStream input)
Parameter
NameDescription
inputInputStream
Returns
TypeDescription
ExecutionStageSummary
Exceptions
TypeDescription
IOException

parseFrom(InputStream input, ExtensionRegistryLite extensionRegistry)

public static ExecutionStageSummary parseFrom(InputStream input, ExtensionRegistryLite extensionRegistry)
Parameters
NameDescription
inputInputStream
extensionRegistryExtensionRegistryLite
Returns
TypeDescription
ExecutionStageSummary
Exceptions
TypeDescription
IOException

parseFrom(ByteBuffer data)

public static ExecutionStageSummary parseFrom(ByteBuffer data)
Parameter
NameDescription
dataByteBuffer
Returns
TypeDescription
ExecutionStageSummary
Exceptions
TypeDescription
InvalidProtocolBufferException

parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)

public static ExecutionStageSummary parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)
Parameters
NameDescription
dataByteBuffer
extensionRegistryExtensionRegistryLite
Returns
TypeDescription
ExecutionStageSummary
Exceptions
TypeDescription
InvalidProtocolBufferException

parser()

public static Parser<ExecutionStageSummary> parser()
Returns
TypeDescription
Parser<ExecutionStageSummary>

Methods

equals(Object obj)

public boolean equals(Object obj)
Parameter
NameDescription
objObject
Returns
TypeDescription
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
NameDescription
indexint
Returns
TypeDescription
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
TypeDescription
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
TypeDescription
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
NameDescription
indexint
Returns
TypeDescription
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
TypeDescription
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
NameDescription
indexint
Returns
TypeDescription
ExecutionStageSummary.ComponentTransform

getComponentTransformCount()

public int getComponentTransformCount()

Transforms that comprise this execution stage.

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

Returns
TypeDescription
int

getComponentTransformList()

public List<ExecutionStageSummary.ComponentTransform> getComponentTransformList()

Transforms that comprise this execution stage.

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

Returns
TypeDescription
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
NameDescription
indexint
Returns
TypeDescription
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
TypeDescription
List<? extends com.google.dataflow.v1beta3.ExecutionStageSummary.ComponentTransformOrBuilder>

getDefaultInstanceForType()

public ExecutionStageSummary getDefaultInstanceForType()
Returns
TypeDescription
ExecutionStageSummary

getId()

public String getId()

Dataflow service generated id for this stage.

string id = 2;

Returns
TypeDescription
String

The id.

getIdBytes()

public ByteString getIdBytes()

Dataflow service generated id for this stage.

string id = 2;

Returns
TypeDescription
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
NameDescription
indexint
Returns
TypeDescription
ExecutionStageSummary.StageSource

getInputSourceCount()

public int getInputSourceCount()

Input sources for this stage.

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

Returns
TypeDescription
int

getInputSourceList()

public List<ExecutionStageSummary.StageSource> getInputSourceList()

Input sources for this stage.

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

Returns
TypeDescription
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
NameDescription
indexint
Returns
TypeDescription
ExecutionStageSummary.StageSourceOrBuilder

getInputSourceOrBuilderList()

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

Input sources for this stage.

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

Returns
TypeDescription
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
TypeDescription
KindType

The kind.

getKindValue()

public int getKindValue()

Type of transform this stage is executing.

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

Returns
TypeDescription
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
TypeDescription
String

The name.

getNameBytes()

public ByteString getNameBytes()

Dataflow service generated name for this stage.

string name = 1;

Returns
TypeDescription
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
NameDescription
indexint
Returns
TypeDescription
ExecutionStageSummary.StageSource

getOutputSourceCount()

public int getOutputSourceCount()

Output sources for this stage.

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

Returns
TypeDescription
int

getOutputSourceList()

public List<ExecutionStageSummary.StageSource> getOutputSourceList()

Output sources for this stage.

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

Returns
TypeDescription
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
NameDescription
indexint
Returns
TypeDescription
ExecutionStageSummary.StageSourceOrBuilder

getOutputSourceOrBuilderList()

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

Output sources for this stage.

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

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

getParserForType()

public Parser<ExecutionStageSummary> getParserForType()
Returns
TypeDescription
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
NameDescription
indexint

The index of the element to return.

Returns
TypeDescription
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
NameDescription
indexint

The index of the value to return.

Returns
TypeDescription
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
TypeDescription
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
TypeDescription
ProtocolStringList

A list containing the prerequisiteStage.

getSerializedSize()

public int getSerializedSize()
Returns
TypeDescription
int
Overrides

hashCode()

public int hashCode()
Returns
TypeDescription
int
Overrides

internalGetFieldAccessorTable()

protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
Returns
TypeDescription
FieldAccessorTable
Overrides

isInitialized()

public final boolean isInitialized()
Returns
TypeDescription
boolean
Overrides

newBuilderForType()

public ExecutionStageSummary.Builder newBuilderForType()
Returns
TypeDescription
ExecutionStageSummary.Builder

newBuilderForType(GeneratedMessageV3.BuilderParent parent)

protected ExecutionStageSummary.Builder newBuilderForType(GeneratedMessageV3.BuilderParent parent)
Parameter
NameDescription
parentBuilderParent
Returns
TypeDescription
ExecutionStageSummary.Builder
Overrides

newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)

protected Object newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
Parameter
NameDescription
unusedUnusedPrivateParameter
Returns
TypeDescription
Object
Overrides

toBuilder()

public ExecutionStageSummary.Builder toBuilder()
Returns
TypeDescription
ExecutionStageSummary.Builder

writeTo(CodedOutputStream output)

public void writeTo(CodedOutputStream output)
Parameter
NameDescription
outputCodedOutputStream
Overrides
Exceptions
TypeDescription
IOException