Package com.google.dataflow.v1beta3

Class 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.GeneratedMessageV3.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 Detail

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

      • internalGetMutableMapField

        protected com.google.protobuf.MapField internalGetMutableMapField​(int number)
        Overrides:
        internalGetMutableMapField in class com.google.protobuf.GeneratedMessageV3.Builder<TopologyConfig.Builder>

      • internalGetFieldAccessorTable

        protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
        Specified by:
        internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessageV3.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.GeneratedMessageV3.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.GeneratedMessageV3.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

      • clone

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

      • setField

        public TopologyConfig.Builder setField​(com.google.protobuf.Descriptors.FieldDescriptor field,
                                       Object value)
        Specified by:
        setField in interface com.google.protobuf.Message.Builder
        Overrides:
        setField in class com.google.protobuf.GeneratedMessageV3.Builder<TopologyConfig.Builder>

      • clearField

        public TopologyConfig.Builder clearField​(com.google.protobuf.Descriptors.FieldDescriptor field)
        Specified by:
        clearField in interface com.google.protobuf.Message.Builder
        Overrides:
        clearField in class com.google.protobuf.GeneratedMessageV3.Builder<TopologyConfig.Builder>

      • clearOneof

        public TopologyConfig.Builder clearOneof​(com.google.protobuf.Descriptors.OneofDescriptor oneof)
        Specified by:
        clearOneof in interface com.google.protobuf.Message.Builder
        Overrides:
        clearOneof in class com.google.protobuf.GeneratedMessageV3.Builder<TopologyConfig.Builder>

      • setRepeatedField

        public TopologyConfig.Builder setRepeatedField​(com.google.protobuf.Descriptors.FieldDescriptor field,
                                               int index,
                                               Object value)
        Specified by:
        setRepeatedField in interface com.google.protobuf.Message.Builder
        Overrides:
        setRepeatedField in class com.google.protobuf.GeneratedMessageV3.Builder<TopologyConfig.Builder>

      • addRepeatedField

        public TopologyConfig.Builder addRepeatedField​(com.google.protobuf.Descriptors.FieldDescriptor field,
                                               Object value)
        Specified by:
        addRepeatedField in interface com.google.protobuf.Message.Builder
        Overrides:
        addRepeatedField in class com.google.protobuf.GeneratedMessageV3.Builder<TopologyConfig.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>

      • isInitialized

        public final boolean isInitialized()
        Specified by:
        isInitialized in interface com.google.protobuf.MessageLiteOrBuilder
        Overrides:
        isInitialized in class com.google.protobuf.GeneratedMessageV3.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

      • 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

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

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

      • 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

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

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

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

      • setUnknownFields

        public final TopologyConfig.Builder setUnknownFields​(com.google.protobuf.UnknownFieldSet unknownFields)
        Specified by:
        setUnknownFields in interface com.google.protobuf.Message.Builder
        Overrides:
        setUnknownFields in class com.google.protobuf.GeneratedMessageV3.Builder<TopologyConfig.Builder>

      • mergeUnknownFields

        public final TopologyConfig.Builder mergeUnknownFields​(com.google.protobuf.UnknownFieldSet unknownFields)
        Specified by:
        mergeUnknownFields in interface com.google.protobuf.Message.Builder
        Overrides:
        mergeUnknownFields in class com.google.protobuf.GeneratedMessageV3.Builder<TopologyConfig.Builder>