Package com.google.dataflow.v1beta3

Class TopologyConfig

java.lang.Object

com.google.protobuf.AbstractMessageLite

com.google.protobuf.AbstractMessage

com.google.protobuf.GeneratedMessageV3

com.google.dataflow.v1beta3.TopologyConfig

All Implemented Interfaces:

TopologyConfigOrBuilder, com.google.protobuf.Message, com.google.protobuf.MessageLite, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Serializable

public final class TopologyConfig
extends com.google.protobuf.GeneratedMessageV3
implements TopologyConfigOrBuilder

 Global topology of the streaming Dataflow job, including all
 computations and their sharded locations.
 

Protobuf type google.dataflow.v1beta3.TopologyConfig

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TopologyConfig.Builder	Global topology of the streaming Dataflow job, including all computations and their sharded locations.

Nested classes/interfaces inherited from class com.google.protobuf.GeneratedMessageV3

com.google.protobuf.GeneratedMessageV3.BuilderParent, com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>,BuilderT extends com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageT,BuilderT>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessageOrBuilder<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessageV3.FieldAccessorTable, com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter

Nested classes/interfaces inherited from class com.google.protobuf.AbstractMessageLite

com.google.protobuf.AbstractMessageLite.InternalOneOfEnum

Field Summary

Fields

Modifier and Type	Field	Description
static int	COMPUTATIONS_FIELD_NUMBER
static int	DATA_DISK_ASSIGNMENTS_FIELD_NUMBER
static int	FORWARDING_KEY_BITS_FIELD_NUMBER
static int	PERSISTENT_STATE_VERSION_FIELD_NUMBER
static int	USER_STAGE_TO_COMPUTATION_NAME_MAP_FIELD_NUMBER

Fields inherited from class com.google.protobuf.GeneratedMessageV3

alwaysUseFieldBuilders, unknownFields

Fields inherited from class com.google.protobuf.AbstractMessage

memoizedSize

Fields inherited from class com.google.protobuf.AbstractMessageLite

memoizedHashCode

Method Summary

Modifier and Type	Method	Description
boolean	containsUserStageToComputationNameMap(String key)	Maps user stage names to stable computation names.
boolean	equals(Object obj)
ComputationTopology	getComputations(int index)	The computations associated with a streaming Dataflow job.
int	getComputationsCount()	The computations associated with a streaming Dataflow job.
List<ComputationTopology>	getComputationsList()	The computations associated with a streaming Dataflow job.
ComputationTopologyOrBuilder	getComputationsOrBuilder(int index)	The computations associated with a streaming Dataflow job.
List<? extends ComputationTopologyOrBuilder>	getComputationsOrBuilderList()	The computations associated with a streaming Dataflow job.
DataDiskAssignment	getDataDiskAssignments(int index)	The disks assigned to a streaming Dataflow job.
int	getDataDiskAssignmentsCount()	The disks assigned to a streaming Dataflow job.
List<DataDiskAssignment>	getDataDiskAssignmentsList()	The disks assigned to a streaming Dataflow job.
DataDiskAssignmentOrBuilder	getDataDiskAssignmentsOrBuilder(int index)	The disks assigned to a streaming Dataflow job.
List<? extends DataDiskAssignmentOrBuilder>	getDataDiskAssignmentsOrBuilderList()	The disks assigned to a streaming Dataflow job.
static TopologyConfig	getDefaultInstance()
TopologyConfig	getDefaultInstanceForType()
static com.google.protobuf.Descriptors.Descriptor	getDescriptor()
int	getForwardingKeyBits()	The size (in bits) of keys that will be assigned to source messages.
com.google.protobuf.Parser<TopologyConfig>	getParserForType()
int	getPersistentStateVersion()	Version number for persistent state.
int	getSerializedSize()
Map<String,String>	getUserStageToComputationNameMap()	Deprecated.
int	getUserStageToComputationNameMapCount()	Maps user stage names to stable computation names.
Map<String,String>	getUserStageToComputationNameMapMap()	Maps user stage names to stable computation names.
String	getUserStageToComputationNameMapOrDefault(String key, String defaultValue)	Maps user stage names to stable computation names.
String	getUserStageToComputationNameMapOrThrow(String key)	Maps user stage names to stable computation names.
int	hashCode()
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable	internalGetFieldAccessorTable()
protected com.google.protobuf.MapField	internalGetMapField(int number)
boolean	isInitialized()
static TopologyConfig.Builder	newBuilder()
static TopologyConfig.Builder	newBuilder(TopologyConfig prototype)
TopologyConfig.Builder	newBuilderForType()
protected TopologyConfig.Builder	newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
protected Object	newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)
static TopologyConfig	parseDelimitedFrom(InputStream input)
static TopologyConfig	parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static TopologyConfig	parseFrom(byte[] data)
static TopologyConfig	parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static TopologyConfig	parseFrom(com.google.protobuf.ByteString data)
static TopologyConfig	parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static TopologyConfig	parseFrom(com.google.protobuf.CodedInputStream input)
static TopologyConfig	parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static TopologyConfig	parseFrom(InputStream input)
static TopologyConfig	parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static TopologyConfig	parseFrom(ByteBuffer data)
static TopologyConfig	parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static com.google.protobuf.Parser<TopologyConfig>	parser()
TopologyConfig.Builder	toBuilder()
void	writeTo(com.google.protobuf.CodedOutputStream output)

Methods inherited from class com.google.protobuf.GeneratedMessageV3

canUseUnsafe, computeStringSize, computeStringSizeNoTag, emptyBooleanList, emptyDoubleList, emptyFloatList, emptyIntList, emptyLongList, getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, isStringEmpty, makeExtensionsImmutable, makeMutableCopy, mergeFromAndMakeImmutableInternal, mutableCopy, mutableCopy, mutableCopy, mutableCopy, mutableCopy, newBooleanList, newBuilderForType, newDoubleList, newFloatList, newIntList, newLongList, parseDelimitedWithIOException, parseDelimitedWithIOException, parseUnknownField, parseUnknownFieldProto3, parseWithIOException, parseWithIOException, parseWithIOException, parseWithIOException, serializeBooleanMapTo, serializeIntegerMapTo, serializeLongMapTo, serializeStringMapTo, writeReplace, writeString, writeStringNoTag

Methods inherited from class com.google.protobuf.AbstractMessage

findInitializationErrors, getInitializationErrorString, hashBoolean, hashEnum, hashEnumList, hashFields, hashLong, toString

Methods inherited from class com.google.protobuf.AbstractMessageLite

addAll, addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeTo

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.google.protobuf.MessageLite

toByteArray, toByteString, writeDelimitedTo, writeTo

Methods inherited from interface com.google.protobuf.MessageOrBuilder

findInitializationErrors, getAllFields, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof

Field Detail

COMPUTATIONS_FIELD_NUMBER

public static final int COMPUTATIONS_FIELD_NUMBER

See Also:

Constant Field Values

DATA_DISK_ASSIGNMENTS_FIELD_NUMBER

public static final int DATA_DISK_ASSIGNMENTS_FIELD_NUMBER

See Also:

Constant Field Values

USER_STAGE_TO_COMPUTATION_NAME_MAP_FIELD_NUMBER

public static final int USER_STAGE_TO_COMPUTATION_NAME_MAP_FIELD_NUMBER

See Also:

Constant Field Values

FORWARDING_KEY_BITS_FIELD_NUMBER

public static final int FORWARDING_KEY_BITS_FIELD_NUMBER

See Also:

Constant Field Values

PERSISTENT_STATE_VERSION_FIELD_NUMBER

public static final int PERSISTENT_STATE_VERSION_FIELD_NUMBER

See Also:

Constant Field Values

Method Detail

newInstance

protected Object newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)

Overrides:

newInstance in class com.google.protobuf.GeneratedMessageV3

getDescriptor

public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()

internalGetMapField

protected com.google.protobuf.MapField internalGetMapField(int number)

Overrides:

internalGetMapField in class com.google.protobuf.GeneratedMessageV3

internalGetFieldAccessorTable

protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()

Specified by:

internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessageV3

getComputationsList

public List<ComputationTopology> getComputationsList()

 The computations associated with a streaming Dataflow job.
 

repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

Specified by:

getComputationsList in interface TopologyConfigOrBuilder

getComputationsOrBuilderList

public List<? extends ComputationTopologyOrBuilder> getComputationsOrBuilderList()

 The computations associated with a streaming Dataflow job.
 

repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

Specified by:

getComputationsOrBuilderList in interface TopologyConfigOrBuilder

getComputationsCount

public int getComputationsCount()

 The computations associated with a streaming Dataflow job.
 

repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

Specified by:

getComputationsCount in interface TopologyConfigOrBuilder

getComputations

public ComputationTopology getComputations(int index)

 The computations associated with a streaming Dataflow job.
 

repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

Specified by:

getComputations in interface TopologyConfigOrBuilder

getComputationsOrBuilder

public ComputationTopologyOrBuilder getComputationsOrBuilder(int index)

 The computations associated with a streaming Dataflow job.
 

repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

Specified by:

getComputationsOrBuilder in interface TopologyConfigOrBuilder

getDataDiskAssignmentsList

public List<DataDiskAssignment> getDataDiskAssignmentsList()

 The disks assigned to a streaming Dataflow job.
 

repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

Specified by:

getDataDiskAssignmentsList in interface TopologyConfigOrBuilder

getDataDiskAssignmentsOrBuilderList

public List<? extends DataDiskAssignmentOrBuilder> getDataDiskAssignmentsOrBuilderList()

 The disks assigned to a streaming Dataflow job.
 

repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

Specified by:

getDataDiskAssignmentsOrBuilderList in interface TopologyConfigOrBuilder

getDataDiskAssignmentsCount

public int getDataDiskAssignmentsCount()

 The disks assigned to a streaming Dataflow job.
 

repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

Specified by:

getDataDiskAssignmentsCount in interface TopologyConfigOrBuilder

getDataDiskAssignments

public DataDiskAssignment getDataDiskAssignments(int index)

 The disks assigned to a streaming Dataflow job.
 

repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

Specified by:

getDataDiskAssignments in interface TopologyConfigOrBuilder

getDataDiskAssignmentsOrBuilder

public DataDiskAssignmentOrBuilder getDataDiskAssignmentsOrBuilder(int index)

 The disks assigned to a streaming Dataflow job.
 

repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

Specified by:

getDataDiskAssignmentsOrBuilder in interface TopologyConfigOrBuilder

getUserStageToComputationNameMapCount

public int getUserStageToComputationNameMapCount()

Description copied from interface: TopologyConfigOrBuilder

 Maps user stage names to stable computation names.
 

map<string, string> user_stage_to_computation_name_map = 3;

Specified by:

getUserStageToComputationNameMapCount in interface TopologyConfigOrBuilder

containsUserStageToComputationNameMap

public boolean containsUserStageToComputationNameMap(String key)

 Maps user stage names to stable computation names.
 

map<string, string> user_stage_to_computation_name_map = 3;

Specified by:

containsUserStageToComputationNameMap in interface TopologyConfigOrBuilder

getUserStageToComputationNameMap

@Deprecated
public Map<String,String> getUserStageToComputationNameMap()

Deprecated.

Use getUserStageToComputationNameMapMap() instead.

Specified by:

getUserStageToComputationNameMap in interface TopologyConfigOrBuilder

getUserStageToComputationNameMapMap

public Map<String,String> getUserStageToComputationNameMapMap()

 Maps user stage names to stable computation names.
 

map<string, string> user_stage_to_computation_name_map = 3;

Specified by:

getUserStageToComputationNameMapMap in interface TopologyConfigOrBuilder

getUserStageToComputationNameMapOrDefault

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;

Specified by:

getUserStageToComputationNameMapOrDefault in interface TopologyConfigOrBuilder

getUserStageToComputationNameMapOrThrow

public String getUserStageToComputationNameMapOrThrow(String key)

 Maps user stage names to stable computation names.
 

map<string, string> user_stage_to_computation_name_map = 3;

Specified by:

getUserStageToComputationNameMapOrThrow in interface TopologyConfigOrBuilder

getForwardingKeyBits

public int getForwardingKeyBits()

 The size (in bits) of keys that will be assigned to source messages.
 

int32 forwarding_key_bits = 4;

Specified by:

getForwardingKeyBits in interface TopologyConfigOrBuilder

Returns:

The forwardingKeyBits.

getPersistentStateVersion

public int getPersistentStateVersion()

 Version number for persistent state.
 

int32 persistent_state_version = 5;

Specified by:

getPersistentStateVersion in interface TopologyConfigOrBuilder

Returns:

The persistentStateVersion.

isInitialized

public final boolean isInitialized()

Specified by:

isInitialized in interface com.google.protobuf.MessageLiteOrBuilder

Overrides:

isInitialized in class com.google.protobuf.GeneratedMessageV3

writeTo

public void writeTo(com.google.protobuf.CodedOutputStream output)
             throws IOException

Specified by:

writeTo in interface com.google.protobuf.MessageLite

Overrides:

writeTo in class com.google.protobuf.GeneratedMessageV3

Throws:

IOException

getSerializedSize

public int getSerializedSize()

Specified by:

getSerializedSize in interface com.google.protobuf.MessageLite

Overrides:

getSerializedSize in class com.google.protobuf.GeneratedMessageV3

equals

public boolean equals(Object obj)

Specified by:

equals in interface com.google.protobuf.Message

Overrides:

equals in class com.google.protobuf.AbstractMessage

hashCode

public int hashCode()

Specified by:

hashCode in interface com.google.protobuf.Message

Overrides:

hashCode in class com.google.protobuf.AbstractMessage

parseFrom

public static TopologyConfig parseFrom(ByteBuffer data)
                                throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static TopologyConfig parseFrom(ByteBuffer data,
                                       com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static TopologyConfig parseFrom(com.google.protobuf.ByteString data)
                                throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static TopologyConfig parseFrom(com.google.protobuf.ByteString data,
                                       com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static TopologyConfig parseFrom(byte[] data)
                                throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static TopologyConfig parseFrom(byte[] data,
                                       com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static TopologyConfig parseFrom(InputStream input)
                                throws IOException

Throws:

IOException

parseFrom

public static TopologyConfig parseFrom(InputStream input,
                                       com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                throws IOException

Throws:

IOException

parseDelimitedFrom

public static TopologyConfig parseDelimitedFrom(InputStream input)
                                         throws IOException

Throws:

IOException

parseDelimitedFrom

public static TopologyConfig parseDelimitedFrom(InputStream input,
                                                com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                         throws IOException

Throws:

IOException

parseFrom

public static TopologyConfig parseFrom(com.google.protobuf.CodedInputStream input)
                                throws IOException

Throws:

IOException

parseFrom

public static TopologyConfig parseFrom(com.google.protobuf.CodedInputStream input,
                                       com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                throws IOException

Throws:

IOException

newBuilderForType

public TopologyConfig.Builder newBuilderForType()

Specified by:

newBuilderForType in interface com.google.protobuf.Message

Specified by:

newBuilderForType in interface com.google.protobuf.MessageLite

newBuilder

public static TopologyConfig.Builder newBuilder()

newBuilder

public static TopologyConfig.Builder newBuilder(TopologyConfig prototype)

toBuilder

public TopologyConfig.Builder toBuilder()

Specified by:

toBuilder in interface com.google.protobuf.Message

Specified by:

toBuilder in interface com.google.protobuf.MessageLite

newBuilderForType

protected TopologyConfig.Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)

Specified by:

newBuilderForType in class com.google.protobuf.GeneratedMessageV3

getDefaultInstance

public static TopologyConfig getDefaultInstance()

parser

public static com.google.protobuf.Parser<TopologyConfig> parser()

getParserForType

public com.google.protobuf.Parser<TopologyConfig> getParserForType()

Specified by:

getParserForType in interface com.google.protobuf.Message

Specified by:

getParserForType in interface com.google.protobuf.MessageLite

Overrides:

getParserForType in class com.google.protobuf.GeneratedMessageV3

getDefaultInstanceForType

public TopologyConfig getDefaultInstanceForType()

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder