Package com.google.dataflow.v1beta3

Class TopologyConfig.Builder

java.lang.Object
com.google.protobuf.AbstractMessageLite.Builder
com.google.protobuf.AbstractMessage.Builder<BuilderT>
com.google.protobuf.GeneratedMessage.Builder<TopologyConfig.Builder>
com.google.dataflow.v1beta3.TopologyConfig.Builder
All Implemented Interfaces:
TopologyConfigOrBuilder, com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Cloneable
Enclosing class:
TopologyConfig
public static final class TopologyConfig.Builder extends com.google.protobuf.GeneratedMessage.Builder<TopologyConfig.Builder> implements TopologyConfigOrBuilder
 Global topology of the streaming Dataflow job, including all
 computations and their sharded locations.
Protobuf type google.dataflow.v1beta3.TopologyConfig

  • 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.Builder<TopologyConfig.Builder>

    • internalGetMutableMapFieldReflection

      protected com.google.protobuf.MapFieldReflectionAccessor internalGetMutableMapFieldReflection(int number)
      Overrides:
      internalGetMutableMapFieldReflection in class com.google.protobuf.GeneratedMessage.Builder<TopologyConfig.Builder>

    • internalGetFieldAccessorTable

      protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()
      Specified by:
      internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessage.Builder<TopologyConfig.Builder>

    • clear

      public TopologyConfig.Builder clear()
      Specified by:
      clear in interface com.google.protobuf.Message.Builder
      Specified by:
      clear in interface com.google.protobuf.MessageLite.Builder
      Overrides:
      clear in class com.google.protobuf.GeneratedMessage.Builder<TopologyConfig.Builder>

    • getDescriptorForType

      public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
      Specified by:
      getDescriptorForType in interface com.google.protobuf.Message.Builder
      Specified by:
      getDescriptorForType in interface com.google.protobuf.MessageOrBuilder
      Overrides:
      getDescriptorForType in class com.google.protobuf.GeneratedMessage.Builder<TopologyConfig.Builder>

    • getDefaultInstanceForType

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

    • build

      public TopologyConfig build()
      Specified by:
      build in interface com.google.protobuf.Message.Builder
      Specified by:
      build in interface com.google.protobuf.MessageLite.Builder

    • buildPartial

      public TopologyConfig buildPartial()
      Specified by:
      buildPartial in interface com.google.protobuf.Message.Builder
      Specified by:
      buildPartial in interface com.google.protobuf.MessageLite.Builder

    • mergeFrom

      public TopologyConfig.Builder mergeFrom(com.google.protobuf.Message other)
      Specified by:
      mergeFrom in interface com.google.protobuf.Message.Builder
      Overrides:
      mergeFrom in class com.google.protobuf.AbstractMessage.Builder<TopologyConfig.Builder>

    • mergeFrom

      public TopologyConfig.Builder mergeFrom(TopologyConfig other)

    • isInitialized

      public final boolean isInitialized()
      Specified by:
      isInitialized in interface com.google.protobuf.MessageLiteOrBuilder
      Overrides:
      isInitialized in class com.google.protobuf.GeneratedMessage.Builder<TopologyConfig.Builder>

    • mergeFrom

      public TopologyConfig.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
      Specified by:
      mergeFrom in interface com.google.protobuf.Message.Builder
      Specified by:
      mergeFrom in interface com.google.protobuf.MessageLite.Builder
      Overrides:
      mergeFrom in class com.google.protobuf.AbstractMessage.Builder<TopologyConfig.Builder>
      Throws:
      IOException

    • 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

    • 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

    • setComputations

      public TopologyConfig.Builder setComputations(int index, ComputationTopology value)
       The computations associated with a streaming Dataflow job.
      repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

    • setComputations

      public TopologyConfig.Builder setComputations(int index, ComputationTopology.Builder builderForValue)
       The computations associated with a streaming Dataflow job.
      repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

    • addComputations

      public TopologyConfig.Builder addComputations(ComputationTopology value)
       The computations associated with a streaming Dataflow job.
      repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

    • addComputations

      public TopologyConfig.Builder addComputations(int index, ComputationTopology value)
       The computations associated with a streaming Dataflow job.
      repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

    • addComputations

      public TopologyConfig.Builder addComputations(ComputationTopology.Builder builderForValue)
       The computations associated with a streaming Dataflow job.
      repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

    • addComputations

      public TopologyConfig.Builder addComputations(int index, ComputationTopology.Builder builderForValue)
       The computations associated with a streaming Dataflow job.
      repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

    • addAllComputations

      public TopologyConfig.Builder addAllComputations(Iterable<? extends ComputationTopology> values)
       The computations associated with a streaming Dataflow job.
      repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

    • clearComputations

      public TopologyConfig.Builder clearComputations()
       The computations associated with a streaming Dataflow job.
      repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

    • removeComputations

      public TopologyConfig.Builder removeComputations(int index)
       The computations associated with a streaming Dataflow job.
      repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

    • getComputationsBuilder

      public ComputationTopology.Builder getComputationsBuilder(int index)
       The computations associated with a streaming Dataflow job.
      repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

    • 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

    • 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

    • addComputationsBuilder

      public ComputationTopology.Builder addComputationsBuilder()
       The computations associated with a streaming Dataflow job.
      repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

    • addComputationsBuilder

      public ComputationTopology.Builder addComputationsBuilder(int index)
       The computations associated with a streaming Dataflow job.
      repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

    • getComputationsBuilderList

      public List<ComputationTopology.Builder> getComputationsBuilderList()
       The computations associated with a streaming Dataflow job.
      repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

    • 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

    • 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

    • setDataDiskAssignments

      public TopologyConfig.Builder setDataDiskAssignments(int index, DataDiskAssignment value)
       The disks assigned to a streaming Dataflow job.
      repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

    • setDataDiskAssignments

      public TopologyConfig.Builder setDataDiskAssignments(int index, DataDiskAssignment.Builder builderForValue)
       The disks assigned to a streaming Dataflow job.
      repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

    • addDataDiskAssignments

      public TopologyConfig.Builder addDataDiskAssignments(DataDiskAssignment value)
       The disks assigned to a streaming Dataflow job.
      repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

    • addDataDiskAssignments

      public TopologyConfig.Builder addDataDiskAssignments(int index, DataDiskAssignment value)
       The disks assigned to a streaming Dataflow job.
      repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

    • addDataDiskAssignments

      public TopologyConfig.Builder addDataDiskAssignments(DataDiskAssignment.Builder builderForValue)
       The disks assigned to a streaming Dataflow job.
      repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

    • addDataDiskAssignments

      public TopologyConfig.Builder addDataDiskAssignments(int index, DataDiskAssignment.Builder builderForValue)
       The disks assigned to a streaming Dataflow job.
      repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

    • addAllDataDiskAssignments

      public TopologyConfig.Builder addAllDataDiskAssignments(Iterable<? extends DataDiskAssignment> values)
       The disks assigned to a streaming Dataflow job.
      repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

    • clearDataDiskAssignments

      public TopologyConfig.Builder clearDataDiskAssignments()
       The disks assigned to a streaming Dataflow job.
      repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

    • removeDataDiskAssignments

      public TopologyConfig.Builder removeDataDiskAssignments(int index)
       The disks assigned to a streaming Dataflow job.
      repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

    • getDataDiskAssignmentsBuilder

      public DataDiskAssignment.Builder getDataDiskAssignmentsBuilder(int index)
       The disks assigned to a streaming Dataflow job.
      repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

    • 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

    • 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

    • addDataDiskAssignmentsBuilder

      public DataDiskAssignment.Builder addDataDiskAssignmentsBuilder()
       The disks assigned to a streaming Dataflow job.
      repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

    • addDataDiskAssignmentsBuilder

      public DataDiskAssignment.Builder addDataDiskAssignmentsBuilder(int index)
       The disks assigned to a streaming Dataflow job.
      repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

    • getDataDiskAssignmentsBuilderList

      public List<DataDiskAssignment.Builder> getDataDiskAssignmentsBuilderList()
       The disks assigned to a streaming Dataflow job.
      repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

    • 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

    • clearUserStageToComputationNameMap

      public TopologyConfig.Builder clearUserStageToComputationNameMap()

    • removeUserStageToComputationNameMap

      public TopologyConfig.Builder removeUserStageToComputationNameMap(String key)
       Maps user stage names to stable computation names.
      map<string, string> user_stage_to_computation_name_map = 3;

    • getMutableUserStageToComputationNameMap

      @Deprecated public Map<String,String> getMutableUserStageToComputationNameMap()
      Deprecated.
      Use alternate mutation accessors instead.

    • putUserStageToComputationNameMap

      public TopologyConfig.Builder putUserStageToComputationNameMap(String key, String value)
       Maps user stage names to stable computation names.
      map<string, string> user_stage_to_computation_name_map = 3;

    • putAllUserStageToComputationNameMap

      public TopologyConfig.Builder putAllUserStageToComputationNameMap(Map<String,String> values)
       Maps user stage names to stable computation names.
      map<string, string> user_stage_to_computation_name_map = 3;

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

    • setForwardingKeyBits

      public TopologyConfig.Builder setForwardingKeyBits(int value)
       The size (in bits) of keys that will be assigned to source messages.
      int32 forwarding_key_bits = 4;
      Parameters:
      value - The forwardingKeyBits to set.
      Returns:
      This builder for chaining.

    • clearForwardingKeyBits

      public TopologyConfig.Builder clearForwardingKeyBits()
       The size (in bits) of keys that will be assigned to source messages.
      int32 forwarding_key_bits = 4;
      Returns:
      This builder for chaining.

    • getPersistentStateVersion

      public int getPersistentStateVersion()
       Version number for persistent state.
      int32 persistent_state_version = 5;
      Specified by:
      getPersistentStateVersion in interface TopologyConfigOrBuilder
      Returns:
      The persistentStateVersion.

    • setPersistentStateVersion

      public TopologyConfig.Builder setPersistentStateVersion(int value)
       Version number for persistent state.
      int32 persistent_state_version = 5;
      Parameters:
      value - The persistentStateVersion to set.
      Returns:
      This builder for chaining.

    • clearPersistentStateVersion

      public TopologyConfig.Builder clearPersistentStateVersion()
       Version number for persistent state.
      int32 persistent_state_version = 5;
      Returns:
      This builder for chaining.