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 |
data | byte[]
|
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 |
key | String
|
equals(Object obj)
public boolean equals(Object obj)
Parameter |
---|
Name | Description |
obj | Object
|
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 |
index | int
|
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 |
index | int
|
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 |
index | int
|
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 |
index | int
|
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;
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 |
key | String
|
hashCode()
Returns |
---|
Type | Description |
int | |
Overrides
internalGetFieldAccessorTable()
protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
Overrides
internalGetMapFieldReflection(int number)
protected MapFieldReflectionAccessor internalGetMapFieldReflection(int number)
Parameter |
---|
Name | Description |
number | int
|
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)
Overrides
toBuilder()
public TopologyConfig.Builder toBuilder()
writeTo(CodedOutputStream output)
public void writeTo(CodedOutputStream output)
Overrides