Send feedback
Class TopologyConfig (0.80.0)
Stay organized with collections
Save and categorize content based on your preferences.
public final class TopologyConfig extends GeneratedMessageV3 implements TopologyConfigOrBuilder
Global topology of the streaming Dataflow job, including all
computations and their sharded locations.
Protobuf type google.dataflow.v1beta3.TopologyConfig
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
COMPUTATIONS_FIELD_NUMBER
public static final int COMPUTATIONS_FIELD_NUMBER
Field Value
Type Description
int
DATA_DISK_ASSIGNMENTS_FIELD_NUMBER
public static final int DATA_DISK_ASSIGNMENTS_FIELD_NUMBER
Field Value
Type Description
int
FORWARDING_KEY_BITS_FIELD_NUMBER
public static final int FORWARDING_KEY_BITS_FIELD_NUMBER
Field Value
Type Description
int
PERSISTENT_STATE_VERSION_FIELD_NUMBER
public static final int PERSISTENT_STATE_VERSION_FIELD_NUMBER
Field Value
Type Description
int
USER_STAGE_TO_COMPUTATION_NAME_MAP_FIELD_NUMBER
public static final int USER_STAGE_TO_COMPUTATION_NAME_MAP_FIELD_NUMBER
Field Value
Type Description
int
Static Methods
getDefaultInstance()
public static TopologyConfig getDefaultInstance ()
getDescriptor()
public static final Descriptors . Descriptor getDescriptor ()
newBuilder()
public static TopologyConfig . Builder newBuilder ()
newBuilder(TopologyConfig prototype)
public static TopologyConfig . Builder newBuilder ( TopologyConfig prototype )
public static TopologyConfig parseDelimitedFrom ( InputStream input )
public static TopologyConfig parseDelimitedFrom ( InputStream input , ExtensionRegistryLite extensionRegistry )
parseFrom(byte[] data)
public static TopologyConfig parseFrom ( byte [] data )
Parameter
Name Description
databyte []
parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)
public static TopologyConfig parseFrom ( byte [] data , ExtensionRegistryLite extensionRegistry )
parseFrom(ByteString data)
public static TopologyConfig parseFrom ( ByteString data )
parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)
public static TopologyConfig parseFrom ( ByteString data , ExtensionRegistryLite extensionRegistry )
public static TopologyConfig parseFrom ( CodedInputStream input )
public static TopologyConfig parseFrom ( CodedInputStream input , ExtensionRegistryLite extensionRegistry )
public static TopologyConfig parseFrom ( InputStream input )
public static TopologyConfig parseFrom ( InputStream input , ExtensionRegistryLite extensionRegistry )
parseFrom(ByteBuffer data)
public static TopologyConfig parseFrom ( ByteBuffer data )
parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)
public static TopologyConfig parseFrom ( ByteBuffer data , ExtensionRegistryLite extensionRegistry )
parser()
public static Parser<TopologyConfig> parser ()
Methods
containsUserStageToComputationNameMap(String key)
public boolean containsUserStageToComputationNameMap ( String key )
Maps user stage names to stable computation names.
map<string, string> user_stage_to_computation_name_map = 3;
Parameter
Name Description
keyString
equals(Object obj)
public boolean equals ( Object obj )
Parameter
Name Description
objObject
Overrides
getComputations(int index)
public ComputationTopology getComputations ( int index )
The computations associated with a streaming Dataflow job.
repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;
Parameter
Name Description
indexint
getComputationsCount()
public int getComputationsCount ()
The computations associated with a streaming Dataflow job.
repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;
Returns
Type Description
int
getComputationsList()
public List<ComputationTopology> getComputationsList ()
The computations associated with a streaming Dataflow job.
repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;
getComputationsOrBuilder(int index)
public ComputationTopologyOrBuilder getComputationsOrBuilder ( int index )
The computations associated with a streaming Dataflow job.
repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;
Parameter
Name Description
indexint
getComputationsOrBuilderList()
public List <? extends ComputationTopologyOrBuilder > getComputationsOrBuilderList ()
The computations associated with a streaming Dataflow job.
repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;
Returns
Type Description
List <? extends com.google.dataflow.v1beta3.ComputationTopologyOrBuilder >
getDataDiskAssignments(int index)
public DataDiskAssignment getDataDiskAssignments ( int index )
The disks assigned to a streaming Dataflow job.
repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;
Parameter
Name Description
indexint
getDataDiskAssignmentsCount()
public int getDataDiskAssignmentsCount ()
The disks assigned to a streaming Dataflow job.
repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;
Returns
Type Description
int
getDataDiskAssignmentsList()
public List<DataDiskAssignment> getDataDiskAssignmentsList ()
The disks assigned to a streaming Dataflow job.
repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;
getDataDiskAssignmentsOrBuilder(int index)
public DataDiskAssignmentOrBuilder getDataDiskAssignmentsOrBuilder ( int index )
The disks assigned to a streaming Dataflow job.
repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;
Parameter
Name Description
indexint
getDataDiskAssignmentsOrBuilderList()
public List <? extends DataDiskAssignmentOrBuilder > getDataDiskAssignmentsOrBuilderList ()
The disks assigned to a streaming Dataflow job.
repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;
Returns
Type Description
List <? extends com.google.dataflow.v1beta3.DataDiskAssignmentOrBuilder >
getDefaultInstanceForType()
public TopologyConfig getDefaultInstanceForType ()
getForwardingKeyBits()
public int getForwardingKeyBits ()
The size (in bits) of keys that will be assigned to source messages.
int32 forwarding_key_bits = 4;
Returns
Type Description
int The forwardingKeyBits.
getParserForType()
public Parser<TopologyConfig> getParserForType ()
Overrides
getPersistentStateVersion()
public int getPersistentStateVersion ()
Version number for persistent state.
int32 persistent_state_version = 5;
Returns
Type Description
int The persistentStateVersion.
getSerializedSize()
public int getSerializedSize ()
Returns
Type Description
int
Overrides
getUserStageToComputationNameMap() (deprecated)
public Map<String , String > getUserStageToComputationNameMap ()
getUserStageToComputationNameMapCount()
public int getUserStageToComputationNameMapCount ()
Maps user stage names to stable computation names.
map<string, string> user_stage_to_computation_name_map = 3;
Returns
Type Description
int
getUserStageToComputationNameMapMap()
public Map<String , String > getUserStageToComputationNameMapMap ()
Maps user stage names to stable computation names.
map<string, string> user_stage_to_computation_name_map = 3;
getUserStageToComputationNameMapOrDefault(String key, String defaultValue)
public String getUserStageToComputationNameMapOrDefault ( String key , String defaultValue )
Maps user stage names to stable computation names.
map<string, string> user_stage_to_computation_name_map = 3;
Returns
Type Description
String
getUserStageToComputationNameMapOrThrow(String key)
public String getUserStageToComputationNameMapOrThrow ( String key )
Maps user stage names to stable computation names.
map<string, string> user_stage_to_computation_name_map = 3;
Parameter
Name Description
keyString
Returns
Type Description
String
hashCode()
Returns
Type Description
int
Overrides
internalGetFieldAccessorTable()
protected GeneratedMessageV3 . FieldAccessorTable internalGetFieldAccessorTable ()
Overrides
internalGetMapFieldReflection(int number)
protected MapFieldReflectionAccessor internalGetMapFieldReflection ( int number )
Parameter
Name Description
numberint
Returns
Type Description
com.google.protobuf.MapFieldReflectionAccessor
Overrides
com.google.protobuf.GeneratedMessageV3.internalGetMapFieldReflection(int)
isInitialized()
public final boolean isInitialized ()
Overrides
newBuilderForType()
public TopologyConfig . Builder newBuilderForType ()
newBuilderForType(GeneratedMessageV3.BuilderParent parent)
protected TopologyConfig . Builder newBuilderForType ( GeneratedMessageV3 . BuilderParent parent )
Overrides
newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
protected Object newInstance ( GeneratedMessageV3 . UnusedPrivateParameter unused )
Returns
Type Description
Object
Overrides
toBuilder()
public TopologyConfig . Builder toBuilder ()
writeTo(CodedOutputStream output)
public void writeTo ( CodedOutputStream output )
Overrides
Send feedback
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 2025-10-11 UTC.
Need to tell us more?
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Hard to understand","hardToUnderstand","thumb-down"],["Incorrect information or sample code","incorrectInformationOrSampleCode","thumb-down"],["Missing the information/samples I need","missingTheInformationSamplesINeed","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2025-10-11 UTC."],[],[]]
