Package com.google.dataflow.v1beta3
Class ComputationTopology
- java.lang.Object
-
- com.google.protobuf.AbstractMessageLite
-
- com.google.protobuf.AbstractMessage
-
- com.google.protobuf.GeneratedMessageV3
-
- com.google.dataflow.v1beta3.ComputationTopology
-
- All Implemented Interfaces:
ComputationTopologyOrBuilder
,com.google.protobuf.Message
,com.google.protobuf.MessageLite
,com.google.protobuf.MessageLiteOrBuilder
,com.google.protobuf.MessageOrBuilder
,Serializable
public final class ComputationTopology extends com.google.protobuf.GeneratedMessageV3 implements ComputationTopologyOrBuilder
All configuration data for a particular Computation.
Protobuf typegoogle.dataflow.v1beta3.ComputationTopology
- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
ComputationTopology.Builder
All configuration data for a particular Computation.-
Nested classes/interfaces inherited from class com.google.protobuf.GeneratedMessageV3
com.google.protobuf.GeneratedMessageV3.BuilderParent, com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>,BuilderT extends com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageT,BuilderT>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessageOrBuilder<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessageV3.FieldAccessorTable, com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter
-
-
Field Summary
Fields Modifier and Type Field Description static int
COMPUTATION_ID_FIELD_NUMBER
static int
INPUTS_FIELD_NUMBER
static int
KEY_RANGES_FIELD_NUMBER
static int
OUTPUTS_FIELD_NUMBER
static int
STATE_FAMILIES_FIELD_NUMBER
static int
SYSTEM_STAGE_NAME_FIELD_NUMBER
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(Object obj)
String
getComputationId()
The ID of the computation.com.google.protobuf.ByteString
getComputationIdBytes()
The ID of the computation.static ComputationTopology
getDefaultInstance()
ComputationTopology
getDefaultInstanceForType()
static com.google.protobuf.Descriptors.Descriptor
getDescriptor()
StreamLocation
getInputs(int index)
The inputs to the computation.int
getInputsCount()
The inputs to the computation.List<StreamLocation>
getInputsList()
The inputs to the computation.StreamLocationOrBuilder
getInputsOrBuilder(int index)
The inputs to the computation.List<? extends StreamLocationOrBuilder>
getInputsOrBuilderList()
The inputs to the computation.KeyRangeLocation
getKeyRanges(int index)
The key ranges processed by the computation.int
getKeyRangesCount()
The key ranges processed by the computation.List<KeyRangeLocation>
getKeyRangesList()
The key ranges processed by the computation.KeyRangeLocationOrBuilder
getKeyRangesOrBuilder(int index)
The key ranges processed by the computation.List<? extends KeyRangeLocationOrBuilder>
getKeyRangesOrBuilderList()
The key ranges processed by the computation.StreamLocation
getOutputs(int index)
The outputs from the computation.int
getOutputsCount()
The outputs from the computation.List<StreamLocation>
getOutputsList()
The outputs from the computation.StreamLocationOrBuilder
getOutputsOrBuilder(int index)
The outputs from the computation.List<? extends StreamLocationOrBuilder>
getOutputsOrBuilderList()
The outputs from the computation.com.google.protobuf.Parser<ComputationTopology>
getParserForType()
int
getSerializedSize()
StateFamilyConfig
getStateFamilies(int index)
The state family values.int
getStateFamiliesCount()
The state family values.List<StateFamilyConfig>
getStateFamiliesList()
The state family values.StateFamilyConfigOrBuilder
getStateFamiliesOrBuilder(int index)
The state family values.List<? extends StateFamilyConfigOrBuilder>
getStateFamiliesOrBuilderList()
The state family values.String
getSystemStageName()
The system stage name.com.google.protobuf.ByteString
getSystemStageNameBytes()
The system stage name.int
hashCode()
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable()
boolean
isInitialized()
static ComputationTopology.Builder
newBuilder()
static ComputationTopology.Builder
newBuilder(ComputationTopology prototype)
ComputationTopology.Builder
newBuilderForType()
protected ComputationTopology.Builder
newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
protected Object
newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)
static ComputationTopology
parseDelimitedFrom(InputStream input)
static ComputationTopology
parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ComputationTopology
parseFrom(byte[] data)
static ComputationTopology
parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ComputationTopology
parseFrom(com.google.protobuf.ByteString data)
static ComputationTopology
parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ComputationTopology
parseFrom(com.google.protobuf.CodedInputStream input)
static ComputationTopology
parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ComputationTopology
parseFrom(InputStream input)
static ComputationTopology
parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ComputationTopology
parseFrom(ByteBuffer data)
static ComputationTopology
parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static com.google.protobuf.Parser<ComputationTopology>
parser()
ComputationTopology.Builder
toBuilder()
void
writeTo(com.google.protobuf.CodedOutputStream output)
-
Methods inherited from class com.google.protobuf.GeneratedMessageV3
canUseUnsafe, computeStringSize, computeStringSizeNoTag, emptyBooleanList, emptyDoubleList, emptyFloatList, emptyIntList, emptyLongList, getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, internalGetMapField, isStringEmpty, makeExtensionsImmutable, makeMutableCopy, mergeFromAndMakeImmutableInternal, mutableCopy, mutableCopy, mutableCopy, mutableCopy, mutableCopy, newBooleanList, newBuilderForType, newDoubleList, newFloatList, newIntList, newLongList, parseDelimitedWithIOException, parseDelimitedWithIOException, parseUnknownField, parseUnknownFieldProto3, parseWithIOException, parseWithIOException, parseWithIOException, parseWithIOException, serializeBooleanMapTo, serializeIntegerMapTo, serializeLongMapTo, serializeStringMapTo, writeReplace, writeString, writeStringNoTag
-
Methods inherited from class com.google.protobuf.AbstractMessage
findInitializationErrors, getInitializationErrorString, hashBoolean, hashEnum, hashEnumList, hashFields, hashLong, toString
-
Methods inherited from class com.google.protobuf.AbstractMessageLite
addAll, addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeTo
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
-
-
-
Field Detail
-
SYSTEM_STAGE_NAME_FIELD_NUMBER
public static final int SYSTEM_STAGE_NAME_FIELD_NUMBER
- See Also:
- Constant Field Values
-
COMPUTATION_ID_FIELD_NUMBER
public static final int COMPUTATION_ID_FIELD_NUMBER
- See Also:
- Constant Field Values
-
KEY_RANGES_FIELD_NUMBER
public static final int KEY_RANGES_FIELD_NUMBER
- See Also:
- Constant Field Values
-
INPUTS_FIELD_NUMBER
public static final int INPUTS_FIELD_NUMBER
- See Also:
- Constant Field Values
-
OUTPUTS_FIELD_NUMBER
public static final int OUTPUTS_FIELD_NUMBER
- See Also:
- Constant Field Values
-
STATE_FAMILIES_FIELD_NUMBER
public static final int STATE_FAMILIES_FIELD_NUMBER
- See Also:
- Constant Field Values
-
-
Method Detail
-
newInstance
protected Object newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)
- Overrides:
newInstance
in classcom.google.protobuf.GeneratedMessageV3
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
-
internalGetFieldAccessorTable
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
- Specified by:
internalGetFieldAccessorTable
in classcom.google.protobuf.GeneratedMessageV3
-
getSystemStageName
public String getSystemStageName()
The system stage name.
string system_stage_name = 1;
- Specified by:
getSystemStageName
in interfaceComputationTopologyOrBuilder
- Returns:
- The systemStageName.
-
getSystemStageNameBytes
public com.google.protobuf.ByteString getSystemStageNameBytes()
The system stage name.
string system_stage_name = 1;
- Specified by:
getSystemStageNameBytes
in interfaceComputationTopologyOrBuilder
- Returns:
- The bytes for systemStageName.
-
getComputationId
public String getComputationId()
The ID of the computation.
string computation_id = 5;
- Specified by:
getComputationId
in interfaceComputationTopologyOrBuilder
- Returns:
- The computationId.
-
getComputationIdBytes
public com.google.protobuf.ByteString getComputationIdBytes()
The ID of the computation.
string computation_id = 5;
- Specified by:
getComputationIdBytes
in interfaceComputationTopologyOrBuilder
- Returns:
- The bytes for computationId.
-
getKeyRangesList
public List<KeyRangeLocation> getKeyRangesList()
The key ranges processed by the computation.
repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
- Specified by:
getKeyRangesList
in interfaceComputationTopologyOrBuilder
-
getKeyRangesOrBuilderList
public List<? extends KeyRangeLocationOrBuilder> getKeyRangesOrBuilderList()
The key ranges processed by the computation.
repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
- Specified by:
getKeyRangesOrBuilderList
in interfaceComputationTopologyOrBuilder
-
getKeyRangesCount
public int getKeyRangesCount()
The key ranges processed by the computation.
repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
- Specified by:
getKeyRangesCount
in interfaceComputationTopologyOrBuilder
-
getKeyRanges
public KeyRangeLocation getKeyRanges(int index)
The key ranges processed by the computation.
repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
- Specified by:
getKeyRanges
in interfaceComputationTopologyOrBuilder
-
getKeyRangesOrBuilder
public KeyRangeLocationOrBuilder getKeyRangesOrBuilder(int index)
The key ranges processed by the computation.
repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
- Specified by:
getKeyRangesOrBuilder
in interfaceComputationTopologyOrBuilder
-
getInputsList
public List<StreamLocation> getInputsList()
The inputs to the computation.
repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
- Specified by:
getInputsList
in interfaceComputationTopologyOrBuilder
-
getInputsOrBuilderList
public List<? extends StreamLocationOrBuilder> getInputsOrBuilderList()
The inputs to the computation.
repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
- Specified by:
getInputsOrBuilderList
in interfaceComputationTopologyOrBuilder
-
getInputsCount
public int getInputsCount()
The inputs to the computation.
repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
- Specified by:
getInputsCount
in interfaceComputationTopologyOrBuilder
-
getInputs
public StreamLocation getInputs(int index)
The inputs to the computation.
repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
- Specified by:
getInputs
in interfaceComputationTopologyOrBuilder
-
getInputsOrBuilder
public StreamLocationOrBuilder getInputsOrBuilder(int index)
The inputs to the computation.
repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
- Specified by:
getInputsOrBuilder
in interfaceComputationTopologyOrBuilder
-
getOutputsList
public List<StreamLocation> getOutputsList()
The outputs from the computation.
repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
- Specified by:
getOutputsList
in interfaceComputationTopologyOrBuilder
-
getOutputsOrBuilderList
public List<? extends StreamLocationOrBuilder> getOutputsOrBuilderList()
The outputs from the computation.
repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
- Specified by:
getOutputsOrBuilderList
in interfaceComputationTopologyOrBuilder
-
getOutputsCount
public int getOutputsCount()
The outputs from the computation.
repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
- Specified by:
getOutputsCount
in interfaceComputationTopologyOrBuilder
-
getOutputs
public StreamLocation getOutputs(int index)
The outputs from the computation.
repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
- Specified by:
getOutputs
in interfaceComputationTopologyOrBuilder
-
getOutputsOrBuilder
public StreamLocationOrBuilder getOutputsOrBuilder(int index)
The outputs from the computation.
repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
- Specified by:
getOutputsOrBuilder
in interfaceComputationTopologyOrBuilder
-
getStateFamiliesList
public List<StateFamilyConfig> getStateFamiliesList()
The state family values.
repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
- Specified by:
getStateFamiliesList
in interfaceComputationTopologyOrBuilder
-
getStateFamiliesOrBuilderList
public List<? extends StateFamilyConfigOrBuilder> getStateFamiliesOrBuilderList()
The state family values.
repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
- Specified by:
getStateFamiliesOrBuilderList
in interfaceComputationTopologyOrBuilder
-
getStateFamiliesCount
public int getStateFamiliesCount()
The state family values.
repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
- Specified by:
getStateFamiliesCount
in interfaceComputationTopologyOrBuilder
-
getStateFamilies
public StateFamilyConfig getStateFamilies(int index)
The state family values.
repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
- Specified by:
getStateFamilies
in interfaceComputationTopologyOrBuilder
-
getStateFamiliesOrBuilder
public StateFamilyConfigOrBuilder getStateFamiliesOrBuilder(int index)
The state family values.
repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
- Specified by:
getStateFamiliesOrBuilder
in interfaceComputationTopologyOrBuilder
-
isInitialized
public final boolean isInitialized()
- Specified by:
isInitialized
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Overrides:
isInitialized
in classcom.google.protobuf.GeneratedMessageV3
-
writeTo
public void writeTo(com.google.protobuf.CodedOutputStream output) throws IOException
- Specified by:
writeTo
in interfacecom.google.protobuf.MessageLite
- Overrides:
writeTo
in classcom.google.protobuf.GeneratedMessageV3
- Throws:
IOException
-
getSerializedSize
public int getSerializedSize()
- Specified by:
getSerializedSize
in interfacecom.google.protobuf.MessageLite
- Overrides:
getSerializedSize
in classcom.google.protobuf.GeneratedMessageV3
-
equals
public boolean equals(Object obj)
- Specified by:
equals
in interfacecom.google.protobuf.Message
- Overrides:
equals
in classcom.google.protobuf.AbstractMessage
-
hashCode
public int hashCode()
- Specified by:
hashCode
in interfacecom.google.protobuf.Message
- Overrides:
hashCode
in classcom.google.protobuf.AbstractMessage
-
parseFrom
public static ComputationTopology parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static ComputationTopology parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static ComputationTopology parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static ComputationTopology parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static ComputationTopology parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static ComputationTopology parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static ComputationTopology parseFrom(InputStream input) throws IOException
- Throws:
IOException
-
parseFrom
public static ComputationTopology parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
parseDelimitedFrom
public static ComputationTopology parseDelimitedFrom(InputStream input) throws IOException
- Throws:
IOException
-
parseDelimitedFrom
public static ComputationTopology parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
parseFrom
public static ComputationTopology parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
- Throws:
IOException
-
parseFrom
public static ComputationTopology parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
newBuilderForType
public ComputationTopology.Builder newBuilderForType()
- Specified by:
newBuilderForType
in interfacecom.google.protobuf.Message
- Specified by:
newBuilderForType
in interfacecom.google.protobuf.MessageLite
-
newBuilder
public static ComputationTopology.Builder newBuilder()
-
newBuilder
public static ComputationTopology.Builder newBuilder(ComputationTopology prototype)
-
toBuilder
public ComputationTopology.Builder toBuilder()
- Specified by:
toBuilder
in interfacecom.google.protobuf.Message
- Specified by:
toBuilder
in interfacecom.google.protobuf.MessageLite
-
newBuilderForType
protected ComputationTopology.Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
- Specified by:
newBuilderForType
in classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstance
public static ComputationTopology getDefaultInstance()
-
parser
public static com.google.protobuf.Parser<ComputationTopology> parser()
-
getParserForType
public com.google.protobuf.Parser<ComputationTopology> getParserForType()
- Specified by:
getParserForType
in interfacecom.google.protobuf.Message
- Specified by:
getParserForType
in interfacecom.google.protobuf.MessageLite
- Overrides:
getParserForType
in classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstanceForType
public ComputationTopology getDefaultInstanceForType()
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageOrBuilder
-
-