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
Static Fields
COMPUTATIONS_FIELD_NUMBER
public static final int COMPUTATIONS_FIELD_NUMBER
Field Value
DATA_DISK_ASSIGNMENTS_FIELD_NUMBER
public static final int DATA_DISK_ASSIGNMENTS_FIELD_NUMBER
Field Value
FORWARDING_KEY_BITS_FIELD_NUMBER
public static final int FORWARDING_KEY_BITS_FIELD_NUMBER
Field Value
PERSISTENT_STATE_VERSION_FIELD_NUMBER
public static final int PERSISTENT_STATE_VERSION_FIELD_NUMBER
Field Value
USER_STAGE_TO_COMPUTATION_NAME_MAP_FIELD_NUMBER
public static final int USER_STAGE_TO_COMPUTATION_NAME_MAP_FIELD_NUMBER
Field Value
Static Methods
getDefaultInstance()
public static TopologyConfig getDefaultInstance()
Returns
getDescriptor()
public static final Descriptors.Descriptor getDescriptor()
Returns
newBuilder()
public static TopologyConfig.Builder newBuilder()
Returns
newBuilder(TopologyConfig prototype)
public static TopologyConfig.Builder newBuilder(TopologyConfig prototype)
Parameter
Returns
public static TopologyConfig parseDelimitedFrom(InputStream input)
Parameter
Returns
Exceptions
public static TopologyConfig parseDelimitedFrom(InputStream input, ExtensionRegistryLite extensionRegistry)
Parameters
Returns
Exceptions
parseFrom(byte[] data)
public static TopologyConfig parseFrom(byte[] data)
Parameter
Name | Description |
data | byte[]
|
Returns
Exceptions
parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)
public static TopologyConfig parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)
Parameters
Returns
Exceptions
parseFrom(ByteString data)
public static TopologyConfig parseFrom(ByteString data)
Parameter
Returns
Exceptions
parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)
public static TopologyConfig parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)
Parameters
Returns
Exceptions
public static TopologyConfig parseFrom(CodedInputStream input)
Parameter
Returns
Exceptions
public static TopologyConfig parseFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)
Parameters
Returns
Exceptions
public static TopologyConfig parseFrom(InputStream input)
Parameter
Returns
Exceptions
public static TopologyConfig parseFrom(InputStream input, ExtensionRegistryLite extensionRegistry)
Parameters
Returns
Exceptions
parseFrom(ByteBuffer data)
public static TopologyConfig parseFrom(ByteBuffer data)
Parameter
Returns
Exceptions
parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)
public static TopologyConfig parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)
Parameters
Returns
Exceptions
parser()
public static Parser<TopologyConfig> parser()
Returns
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
Returns
equals(Object obj)
public boolean equals(Object obj)
Parameter
Returns
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
Returns
getComputationsCount()
public int getComputationsCount()
The computations associated with a streaming Dataflow job.
repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;
Returns
getComputationsList()
public List<ComputationTopology> getComputationsList()
The computations associated with a streaming Dataflow job.
repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;
Returns
getComputationsOrBuilder(int index)
public ComputationTopologyOrBuilder getComputationsOrBuilder(int index)
The computations associated with a streaming Dataflow job.
repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;
Parameter
Returns
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
Returns
getDataDiskAssignmentsCount()
public int getDataDiskAssignmentsCount()
The disks assigned to a streaming Dataflow job.
repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;
Returns
getDataDiskAssignmentsList()
public List<DataDiskAssignment> getDataDiskAssignmentsList()
The disks assigned to a streaming Dataflow job.
repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;
Returns
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
Returns
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()
Returns
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()
Returns
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
Overrides
getUnknownFields()
public final UnknownFieldSet getUnknownFields()
Returns
Overrides
getUserStageToComputationNameMap()
public Map<String,String> getUserStageToComputationNameMap()
Returns
getUserStageToComputationNameMapCount()
public int getUserStageToComputationNameMapCount()
Maps user stage names to stable computation names.
map<string, string> user_stage_to_computation_name_map = 3;
Returns
getUserStageToComputationNameMapMap()
public Map<String,String> getUserStageToComputationNameMapMap()
Maps user stage names to stable computation names.
map<string, string> user_stage_to_computation_name_map = 3;
Returns
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;
Parameters
Returns
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
Returns
hashCode()
Returns
Overrides
internalGetFieldAccessorTable()
protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
Returns
Overrides
internalGetMapField(int number)
protected MapField internalGetMapField(int number)
Parameter
Returns
Overrides
isInitialized()
public final boolean isInitialized()
Returns
Overrides
newBuilderForType()
public TopologyConfig.Builder newBuilderForType()
Returns
newBuilderForType(GeneratedMessageV3.BuilderParent parent)
protected TopologyConfig.Builder newBuilderForType(GeneratedMessageV3.BuilderParent parent)
Parameter
Returns
Overrides
newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
protected Object newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
Parameter
Returns
Overrides
toBuilder()
public TopologyConfig.Builder toBuilder()
Returns
writeTo(CodedOutputStream output)
public void writeTo(CodedOutputStream output)
Parameter
Overrides
Exceptions