Package com.google.dataflow.v1beta3

Interface TopologyConfigOrBuilder

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

    • Method Detail

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

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