Send feedback
Class TopologyConfig (0.21.0)
bookmark_border bookmark
Stay organized with collections
Save and categorize content based on your preferences.
Version 0.21.0 keyboard_arrow_down
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 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
getUnknownFields()
public final UnknownFieldSet getUnknownFields ()
Overrides
getUserStageToComputationNameMap()
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;
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
hashCode()
Returns Type Description int
Overrides
internalGetFieldAccessorTable()
protected GeneratedMessageV3 . FieldAccessorTable internalGetFieldAccessorTable ()
Overrides
internalGetMapField(int number)
protected MapField internalGetMapField ( int number )
Parameter Name Description numberint
Overrides
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 )
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-03-05 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-03-05 UTC."],[],[]]
