Package com.google.dataflow.v1beta3

Class TopologyConfig

java.lang.Object
com.google.protobuf.AbstractMessageLite
com.google.protobuf.AbstractMessage
com.google.protobuf.GeneratedMessage
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
@Generated public final class TopologyConfig extends com.google.protobuf.GeneratedMessage implements TopologyConfigOrBuilder
 Global topology of the streaming Dataflow job, including all
 computations and their sharded locations.
Protobuf type google.dataflow.v1beta3.TopologyConfig
See Also:

  • Field Details

    • COMPUTATIONS_FIELD_NUMBER

      public static final int COMPUTATIONS_FIELD_NUMBER
      See Also:

    • DATA_DISK_ASSIGNMENTS_FIELD_NUMBER

      public static final int DATA_DISK_ASSIGNMENTS_FIELD_NUMBER
      See Also:

    • USER_STAGE_TO_COMPUTATION_NAME_MAP_FIELD_NUMBER

      public static final int USER_STAGE_TO_COMPUTATION_NAME_MAP_FIELD_NUMBER
      See Also:

    • FORWARDING_KEY_BITS_FIELD_NUMBER

      public static final int FORWARDING_KEY_BITS_FIELD_NUMBER
      See Also:

    • PERSISTENT_STATE_VERSION_FIELD_NUMBER

      public static final int PERSISTENT_STATE_VERSION_FIELD_NUMBER
      See Also:

  • Method Details

    • getDescriptor

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

    • internalGetMapFieldReflection

      protected com.google.protobuf.MapFieldReflectionAccessor internalGetMapFieldReflection(int number)
      Overrides:
      internalGetMapFieldReflection in class com.google.protobuf.GeneratedMessage

    • internalGetFieldAccessorTable

      protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()
      Specified by:
      internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessage

    • 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.GeneratedMessage

    • 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.GeneratedMessage
      Throws:
      IOException

    • getSerializedSize

      public int getSerializedSize()
      Specified by:
      getSerializedSize in interface com.google.protobuf.MessageLite
      Overrides:
      getSerializedSize in class com.google.protobuf.GeneratedMessage

    • 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.AbstractMessage.BuilderParent parent)
      Overrides:
      newBuilderForType in class com.google.protobuf.AbstractMessage

    • 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.GeneratedMessage

    • getDefaultInstanceForType

      public TopologyConfig getDefaultInstanceForType()
      Specified by:
      getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder
      Specified by:
      getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder