Class ComputationTopology (0.51.0)
0.91.0 (latest)
0.89.0
0.87.0
0.86.0
0.85.0
0.84.0
0.82.0
0.80.0
0.79.0
0.78.0
0.77.0
0.76.0
0.74.0
0.72.0
0.71.0
0.68.0
0.67.0
0.66.0
0.64.0
0.63.0
0.62.0
0.61.0
0.60.0
0.59.0
0.58.0
0.57.0
0.56.0
0.55.0
0.53.0
0.52.0
0.51.0
0.50.0
0.49.0
0.48.0
0.47.0
0.46.0
0.45.0
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 ComputationTopology extends GeneratedMessageV3 implements ComputationTopologyOrBuilder
All configuration data for a particular Computation.
Protobuf type google.dataflow.v1beta3.ComputationTopology
Inherited Members
com.google.protobuf.GeneratedMessageV3.<ListT>makeMutableCopy(ListT)
com.google.protobuf.GeneratedMessageV3.<ListT>makeMutableCopy(ListT,int)
com.google.protobuf.GeneratedMessageV3.<T>emptyList(java.lang.Class<T>)
com.google.protobuf.GeneratedMessageV3.internalGetMapFieldReflection(int)
Static Fields
COMPUTATION_ID_FIELD_NUMBER
public static final int COMPUTATION_ID_FIELD_NUMBER
Field Value
Type Description
int
public static final int INPUTS_FIELD_NUMBER
Field Value
Type Description
int
KEY_RANGES_FIELD_NUMBER
public static final int KEY_RANGES_FIELD_NUMBER
Field Value
Type Description
int
OUTPUTS_FIELD_NUMBER
public static final int OUTPUTS_FIELD_NUMBER
Field Value
Type Description
int
STATE_FAMILIES_FIELD_NUMBER
public static final int STATE_FAMILIES_FIELD_NUMBER
Field Value
Type Description
int
SYSTEM_STAGE_NAME_FIELD_NUMBER
public static final int SYSTEM_STAGE_NAME_FIELD_NUMBER
Field Value
Type Description
int
Static Methods
getDefaultInstance()
public static ComputationTopology getDefaultInstance ()
getDescriptor()
public static final Descriptors . Descriptor getDescriptor ()
newBuilder()
public static ComputationTopology . Builder newBuilder ()
newBuilder(ComputationTopology prototype)
public static ComputationTopology . Builder newBuilder ( ComputationTopology prototype )
public static ComputationTopology parseDelimitedFrom ( InputStream input )
public static ComputationTopology parseDelimitedFrom ( InputStream input , ExtensionRegistryLite extensionRegistry )
parseFrom(byte[] data)
public static ComputationTopology parseFrom ( byte [] data )
Parameter
Name Description
databyte []
parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)
public static ComputationTopology parseFrom ( byte [] data , ExtensionRegistryLite extensionRegistry )
parseFrom(ByteString data)
public static ComputationTopology parseFrom ( ByteString data )
parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)
public static ComputationTopology parseFrom ( ByteString data , ExtensionRegistryLite extensionRegistry )
public static ComputationTopology parseFrom ( CodedInputStream input )
public static ComputationTopology parseFrom ( CodedInputStream input , ExtensionRegistryLite extensionRegistry )
public static ComputationTopology parseFrom ( InputStream input )
public static ComputationTopology parseFrom ( InputStream input , ExtensionRegistryLite extensionRegistry )
parseFrom(ByteBuffer data)
public static ComputationTopology parseFrom ( ByteBuffer data )
parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)
public static ComputationTopology parseFrom ( ByteBuffer data , ExtensionRegistryLite extensionRegistry )
parser()
public static Parser<ComputationTopology> parser ()
Methods
equals(Object obj)
public boolean equals ( Object obj )
Parameter
Name Description
objObject
Overrides
getComputationId()
public String getComputationId ()
The ID of the computation.
string computation_id = 5;
Returns
Type Description
String The computationId.
getComputationIdBytes()
public ByteString getComputationIdBytes ()
The ID of the computation.
string computation_id = 5;
Returns
Type Description
ByteString The bytes for computationId.
getDefaultInstanceForType()
public ComputationTopology getDefaultInstanceForType ()
public StreamLocation getInputs ( int index )
The inputs to the computation.
repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
Parameter
Name Description
indexint
public int getInputsCount ()
The inputs to the computation.
repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
Returns
Type Description
int
public List<StreamLocation> getInputsList ()
The inputs to the computation.
repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
public StreamLocationOrBuilder getInputsOrBuilder ( int index )
The inputs to the computation.
repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
Parameter
Name Description
indexint
public List <? extends StreamLocationOrBuilder > getInputsOrBuilderList ()
The inputs to the computation.
repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
Returns
Type Description
List <? extends com.google.dataflow.v1beta3.StreamLocationOrBuilder >
getKeyRanges(int index)
public KeyRangeLocation getKeyRanges ( int index )
The key ranges processed by the computation.
repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
Parameter
Name Description
indexint
getKeyRangesCount()
public int getKeyRangesCount ()
The key ranges processed by the computation.
repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
Returns
Type Description
int
getKeyRangesList()
public List<KeyRangeLocation> getKeyRangesList ()
The key ranges processed by the computation.
repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
getKeyRangesOrBuilder(int index)
public KeyRangeLocationOrBuilder getKeyRangesOrBuilder ( int index )
The key ranges processed by the computation.
repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
Parameter
Name Description
indexint
getKeyRangesOrBuilderList()
public List <? extends KeyRangeLocationOrBuilder > getKeyRangesOrBuilderList ()
The key ranges processed by the computation.
repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
Returns
Type Description
List <? extends com.google.dataflow.v1beta3.KeyRangeLocationOrBuilder >
getOutputs(int index)
public StreamLocation getOutputs ( int index )
The outputs from the computation.
repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
Parameter
Name Description
indexint
getOutputsCount()
public int getOutputsCount ()
The outputs from the computation.
repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
Returns
Type Description
int
getOutputsList()
public List<StreamLocation> getOutputsList ()
The outputs from the computation.
repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
getOutputsOrBuilder(int index)
public StreamLocationOrBuilder getOutputsOrBuilder ( int index )
The outputs from the computation.
repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
Parameter
Name Description
indexint
getOutputsOrBuilderList()
public List <? extends StreamLocationOrBuilder > getOutputsOrBuilderList ()
The outputs from the computation.
repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
Returns
Type Description
List <? extends com.google.dataflow.v1beta3.StreamLocationOrBuilder >
getParserForType()
public Parser<ComputationTopology> getParserForType ()
Overrides
getSerializedSize()
public int getSerializedSize ()
Returns
Type Description
int
Overrides
getStateFamilies(int index)
public StateFamilyConfig getStateFamilies ( int index )
The state family values.
repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
Parameter
Name Description
indexint
getStateFamiliesCount()
public int getStateFamiliesCount ()
The state family values.
repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
Returns
Type Description
int
getStateFamiliesList()
public List<StateFamilyConfig> getStateFamiliesList ()
The state family values.
repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
getStateFamiliesOrBuilder(int index)
public StateFamilyConfigOrBuilder getStateFamiliesOrBuilder ( int index )
The state family values.
repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
Parameter
Name Description
indexint
getStateFamiliesOrBuilderList()
public List <? extends StateFamilyConfigOrBuilder > getStateFamiliesOrBuilderList ()
The state family values.
repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
Returns
Type Description
List <? extends com.google.dataflow.v1beta3.StateFamilyConfigOrBuilder >
getSystemStageName()
public String getSystemStageName ()
The system stage name.
string system_stage_name = 1;
Returns
Type Description
String The systemStageName.
getSystemStageNameBytes()
public ByteString getSystemStageNameBytes ()
The system stage name.
string system_stage_name = 1;
Returns
Type Description
ByteString The bytes for systemStageName.
hashCode()
Returns
Type Description
int
Overrides
internalGetFieldAccessorTable()
protected GeneratedMessageV3 . FieldAccessorTable internalGetFieldAccessorTable ()
Overrides
isInitialized()
public final boolean isInitialized ()
Overrides
newBuilderForType()
public ComputationTopology . Builder newBuilderForType ()
newBuilderForType(GeneratedMessageV3.BuilderParent parent)
protected ComputationTopology . Builder newBuilderForType ( GeneratedMessageV3 . BuilderParent parent )
Overrides
newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
protected Object newInstance ( GeneratedMessageV3 . UnusedPrivateParameter unused )
Returns
Type Description
Object
Overrides
toBuilder()
public ComputationTopology . Builder toBuilder ()
writeTo(CodedOutputStream output)
public void writeTo ( CodedOutputStream output )
Overrides
Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License , and code samples are licensed under the Apache 2.0 License . For details, see the Google Developers Site Policies . Java is a registered trademark of Oracle and/or its affiliates.
Last updated 2026-03-14 UTC.
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Missing the information I need","missingTheInformationINeed","thumb-down"],["Too complicated / too many steps","tooComplicatedTooManySteps","thumb-down"],["Out of date","outOfDate","thumb-down"],["Samples / code issue","samplesCodeIssue","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2026-03-14 UTC."],[],[]]
