Class ExecutionStageSummary (0.8.0)

Version 0.8.0

• 0.45.0 (latest)
• 0.44.0
• 0.43.0
• 0.41.0
• 0.40.0
• 0.39.0
• 0.38.0
• 0.37.0
• 0.36.0
• 0.35.0
• 0.34.0
• 0.33.0
• 0.32.0
• 0.31.0
• 0.28.0
• 0.27.0
• 0.26.0
• 0.25.0
• 0.24.0
• 0.23.0
• 0.22.0
• 0.21.0
• 0.20.0
• 0.19.0
• 0.18.0
• 0.17.0
• 0.16.0
• 0.15.0
• 0.13.0
• 0.12.0
• 0.11.0
• 0.10.0
• 0.9.0
• 0.8.0
• 0.5.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

Inheritance

Object > AbstractMessageLite<MessageType,BuilderType> > AbstractMessage > GeneratedMessageV3 > ExecutionStageSummary

Implements

ExecutionStageSummaryOrBuilder

Inherited Members

AbstractMessage.equals(Object)

AbstractMessage.findInitializationErrors()

AbstractMessage.getInitializationErrorString()

AbstractMessage.hashBoolean(boolean)

AbstractMessage.hashCode()

AbstractMessage.hashEnum(Internal.EnumLite)

AbstractMessage.hashEnumList(List<? extends Internal.EnumLite>)

AbstractMessage.hashFields(int,Map<Descriptors.FieldDescriptor,Object>)

AbstractMessage.hashLong(long)

AbstractMessage.toString()

AbstractMessageLite.<T>addAll(Iterable<T>,Collection<? super T>)

AbstractMessageLite.<T>addAll(Iterable<T>,List<? super T>)

AbstractMessageLite.checkByteStringIsUtf8(ByteString)

AbstractMessageLite.toByteArray()

AbstractMessageLite.toByteString()

AbstractMessageLite.writeDelimitedTo(OutputStream)

AbstractMessageLite.writeTo(OutputStream)

GeneratedMessageV3.<M>parseDelimitedWithIOException(Parser<M>,InputStream)

GeneratedMessageV3.<M>parseDelimitedWithIOException(Parser<M>,InputStream,ExtensionRegistryLite)

GeneratedMessageV3.<M>parseWithIOException(Parser<M>,CodedInputStream)

GeneratedMessageV3.<M>parseWithIOException(Parser<M>,CodedInputStream,ExtensionRegistryLite)

GeneratedMessageV3.<M>parseWithIOException(Parser<M>,InputStream)

GeneratedMessageV3.<M>parseWithIOException(Parser<M>,InputStream,ExtensionRegistryLite)

GeneratedMessageV3.<V>serializeBooleanMapTo(CodedOutputStream,MapField<Boolean,V>,MapEntry<Boolean,V>,int)

GeneratedMessageV3.<V>serializeIntegerMapTo(CodedOutputStream,MapField<Integer,V>,MapEntry<Integer,V>,int)

GeneratedMessageV3.<V>serializeLongMapTo(CodedOutputStream,MapField<Long,V>,MapEntry<Long,V>,int)

GeneratedMessageV3.<V>serializeStringMapTo(CodedOutputStream,MapField<String,V>,MapEntry<String,V>,int)

GeneratedMessageV3.canUseUnsafe()

GeneratedMessageV3.computeStringSize(int,Object)

GeneratedMessageV3.computeStringSizeNoTag(Object)

GeneratedMessageV3.emptyBooleanList()

GeneratedMessageV3.emptyDoubleList()

GeneratedMessageV3.emptyFloatList()

GeneratedMessageV3.emptyIntList()

GeneratedMessageV3.emptyLongList()

GeneratedMessageV3.getAllFields()

GeneratedMessageV3.getDescriptorForType()

GeneratedMessageV3.getField(Descriptors.FieldDescriptor)

GeneratedMessageV3.getOneofFieldDescriptor(Descriptors.OneofDescriptor)

GeneratedMessageV3.getParserForType()

GeneratedMessageV3.getRepeatedField(Descriptors.FieldDescriptor,int)

GeneratedMessageV3.getRepeatedFieldCount(Descriptors.FieldDescriptor)

GeneratedMessageV3.getSerializedSize()

GeneratedMessageV3.getUnknownFields()

GeneratedMessageV3.hasField(Descriptors.FieldDescriptor)

GeneratedMessageV3.hasOneof(Descriptors.OneofDescriptor)

GeneratedMessageV3.internalGetFieldAccessorTable()

GeneratedMessageV3.internalGetMapField(int)

GeneratedMessageV3.isInitialized()

GeneratedMessageV3.isStringEmpty(Object)

GeneratedMessageV3.makeExtensionsImmutable()

GeneratedMessageV3.mergeFromAndMakeImmutableInternal(CodedInputStream,ExtensionRegistryLite)

GeneratedMessageV3.mutableCopy(Internal.BooleanList)

GeneratedMessageV3.mutableCopy(Internal.DoubleList)

GeneratedMessageV3.mutableCopy(Internal.FloatList)

GeneratedMessageV3.mutableCopy(Internal.IntList)

GeneratedMessageV3.mutableCopy(Internal.LongList)

GeneratedMessageV3.newBooleanList()

GeneratedMessageV3.newBuilderForType(AbstractMessage.BuilderParent)

GeneratedMessageV3.newBuilderForType(GeneratedMessageV3.BuilderParent)

GeneratedMessageV3.newDoubleList()

GeneratedMessageV3.newFloatList()

GeneratedMessageV3.newInstance(GeneratedMessageV3.UnusedPrivateParameter)

GeneratedMessageV3.newIntList()

GeneratedMessageV3.newLongList()

GeneratedMessageV3.parseUnknownField(CodedInputStream,UnknownFieldSet.Builder,ExtensionRegistryLite,int)

GeneratedMessageV3.parseUnknownFieldProto3(CodedInputStream,UnknownFieldSet.Builder,ExtensionRegistryLite,int)

GeneratedMessageV3.writeReplace()

GeneratedMessageV3.writeString(CodedOutputStream,int,Object)

GeneratedMessageV3.writeStringNoTag(CodedOutputStream,Object)

GeneratedMessageV3.writeTo(CodedOutputStream)

Object.clone()

Object.finalize()

Object.getClass()

Object.notify()

Object.notifyAll()

Object.wait()

Object.wait(long)

Object.wait(long,int)

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

AbstractMessage.equals(Object other)

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

GeneratedMessageV3.getParserForType()

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

GeneratedMessageV3.getSerializedSize()

getUnknownFields()

public final UnknownFieldSet getUnknownFields()

Returns

Type	Description
UnknownFieldSet

Overrides

GeneratedMessageV3.getUnknownFields()

hashCode()

public int hashCode()

Returns

Type	Description
int

Overrides

AbstractMessage.hashCode()

internalGetFieldAccessorTable()

protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()

Returns

Type	Description
FieldAccessorTable

Overrides

GeneratedMessageV3.internalGetFieldAccessorTable()

isInitialized()

public final boolean isInitialized()

Returns

Type	Description
boolean

Overrides

GeneratedMessageV3.isInitialized()

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

GeneratedMessageV3.newBuilderForType(GeneratedMessageV3.BuilderParent parent)

newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)

protected Object newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)

Parameter

Name	Description
unused	UnusedPrivateParameter

Returns

Type	Description
Object

Overrides

GeneratedMessageV3.newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)

toBuilder()

public ExecutionStageSummary.Builder toBuilder()

Returns

Type	Description
ExecutionStageSummary.Builder

writeTo(CodedOutputStream output)

public void writeTo(CodedOutputStream output)

Parameter

Name	Description
output	CodedOutputStream

Overrides

GeneratedMessageV3.writeTo(CodedOutputStream output)

Exceptions

Type	Description
IOException