Package com.google.dataflow.v1beta3

Interface TopologyConfigOrBuilder

All Superinterfaces:
com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder
All Known Implementing Classes:
TopologyConfig, TopologyConfig.Builder
@Generated public interface TopologyConfigOrBuilder extends com.google.protobuf.MessageOrBuilder

  • Method Details

    • getComputationsList

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

    • getComputations

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

    • getComputationsCount

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

    • getComputationsOrBuilderList

      List<? extends ComputationTopologyOrBuilder> getComputationsOrBuilderList()
       The computations associated with a streaming Dataflow job.
      repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

    • getComputationsOrBuilder

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

    • getDataDiskAssignmentsList

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

    • getDataDiskAssignments

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

    • getDataDiskAssignmentsCount

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

    • getDataDiskAssignmentsOrBuilderList

      List<? extends DataDiskAssignmentOrBuilder> getDataDiskAssignmentsOrBuilderList()
       The disks assigned to a streaming Dataflow job.
      repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

    • getDataDiskAssignmentsOrBuilder

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

    • getUserStageToComputationNameMapCount

      int getUserStageToComputationNameMapCount()
       Maps user stage names to stable computation names.
      map<string, string> user_stage_to_computation_name_map = 3;

    • containsUserStageToComputationNameMap

      boolean containsUserStageToComputationNameMap(String key)
       Maps user stage names to stable computation names.
      map<string, string> user_stage_to_computation_name_map = 3;

    • getUserStageToComputationNameMap

      @Deprecated Map<String,String> getUserStageToComputationNameMap()
      Deprecated.
      Use getUserStageToComputationNameMapMap() instead.

    • getUserStageToComputationNameMapMap

      Map<String,String> getUserStageToComputationNameMapMap()
       Maps user stage names to stable computation names.
      map<string, string> user_stage_to_computation_name_map = 3;

    • getUserStageToComputationNameMapOrDefault

      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 getUserStageToComputationNameMapOrThrow(String key)
       Maps user stage names to stable computation names.
      map<string, string> user_stage_to_computation_name_map = 3;

    • getForwardingKeyBits

      int getForwardingKeyBits()
       The size (in bits) of keys that will be assigned to source messages.
      int32 forwarding_key_bits = 4;
      Returns:
      The forwardingKeyBits.

    • getPersistentStateVersion

      int getPersistentStateVersion()
       Version number for persistent state.
      int32 persistent_state_version = 5;
      Returns:
      The persistentStateVersion.