Package com.google.dataflow.v1beta3

Class ComputationTopology.Builder

java.lang.Object
com.google.protobuf.AbstractMessageLite.Builder
com.google.protobuf.AbstractMessage.Builder<BuilderT>
com.google.protobuf.GeneratedMessage.Builder<ComputationTopology.Builder>
com.google.dataflow.v1beta3.ComputationTopology.Builder
All Implemented Interfaces:
ComputationTopologyOrBuilder, com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Cloneable
Enclosing class:
ComputationTopology
public static final class ComputationTopology.Builder extends com.google.protobuf.GeneratedMessage.Builder<ComputationTopology.Builder> implements ComputationTopologyOrBuilder
 All configuration data for a particular Computation.
Protobuf type google.dataflow.v1beta3.ComputationTopology

  • Method Details

    • getDescriptor

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

    • internalGetFieldAccessorTable

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

    • clear

      public ComputationTopology.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<ComputationTopology.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<ComputationTopology.Builder>

    • getDefaultInstanceForType

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

    • build

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

    • buildPartial

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

    • mergeFrom

      public ComputationTopology.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<ComputationTopology.Builder>

    • mergeFrom

      public ComputationTopology.Builder mergeFrom(ComputationTopology other)

    • isInitialized

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

    • mergeFrom

      public ComputationTopology.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<ComputationTopology.Builder>
      Throws:
      IOException

    • getSystemStageName

      public String getSystemStageName()
       The system stage name.
      string system_stage_name = 1;
      Specified by:
      getSystemStageName in interface ComputationTopologyOrBuilder
      Returns:
      The systemStageName.

    • getSystemStageNameBytes

      public com.google.protobuf.ByteString getSystemStageNameBytes()
       The system stage name.
      string system_stage_name = 1;
      Specified by:
      getSystemStageNameBytes in interface ComputationTopologyOrBuilder
      Returns:
      The bytes for systemStageName.

    • setSystemStageName

      public ComputationTopology.Builder setSystemStageName(String value)
       The system stage name.
      string system_stage_name = 1;
      Parameters:
      value - The systemStageName to set.
      Returns:
      This builder for chaining.

    • clearSystemStageName

      public ComputationTopology.Builder clearSystemStageName()
       The system stage name.
      string system_stage_name = 1;
      Returns:
      This builder for chaining.

    • setSystemStageNameBytes

      public ComputationTopology.Builder setSystemStageNameBytes(com.google.protobuf.ByteString value)
       The system stage name.
      string system_stage_name = 1;
      Parameters:
      value - The bytes for systemStageName to set.
      Returns:
      This builder for chaining.

    • getComputationId

      public String getComputationId()
       The ID of the computation.
      string computation_id = 5;
      Specified by:
      getComputationId in interface ComputationTopologyOrBuilder
      Returns:
      The computationId.

    • getComputationIdBytes

      public com.google.protobuf.ByteString getComputationIdBytes()
       The ID of the computation.
      string computation_id = 5;
      Specified by:
      getComputationIdBytes in interface ComputationTopologyOrBuilder
      Returns:
      The bytes for computationId.

    • setComputationId

      public ComputationTopology.Builder setComputationId(String value)
       The ID of the computation.
      string computation_id = 5;
      Parameters:
      value - The computationId to set.
      Returns:
      This builder for chaining.

    • clearComputationId

      public ComputationTopology.Builder clearComputationId()
       The ID of the computation.
      string computation_id = 5;
      Returns:
      This builder for chaining.

    • setComputationIdBytes

      public ComputationTopology.Builder setComputationIdBytes(com.google.protobuf.ByteString value)
       The ID of the computation.
      string computation_id = 5;
      Parameters:
      value - The bytes for computationId to set.
      Returns:
      This builder for chaining.

    • getKeyRangesList

      public List<KeyRangeLocation> getKeyRangesList()
       The key ranges processed by the computation.
      repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
      Specified by:
      getKeyRangesList in interface ComputationTopologyOrBuilder

    • getKeyRangesCount

      public int getKeyRangesCount()
       The key ranges processed by the computation.
      repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
      Specified by:
      getKeyRangesCount in interface ComputationTopologyOrBuilder

    • getKeyRanges

      public KeyRangeLocation getKeyRanges(int index)
       The key ranges processed by the computation.
      repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
      Specified by:
      getKeyRanges in interface ComputationTopologyOrBuilder

    • setKeyRanges

      public ComputationTopology.Builder setKeyRanges(int index, KeyRangeLocation value)
       The key ranges processed by the computation.
      repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;

    • setKeyRanges

      public ComputationTopology.Builder setKeyRanges(int index, KeyRangeLocation.Builder builderForValue)
       The key ranges processed by the computation.
      repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;

    • addKeyRanges

      public ComputationTopology.Builder addKeyRanges(KeyRangeLocation value)
       The key ranges processed by the computation.
      repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;

    • addKeyRanges

      public ComputationTopology.Builder addKeyRanges(int index, KeyRangeLocation value)
       The key ranges processed by the computation.
      repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;

    • addKeyRanges

      public ComputationTopology.Builder addKeyRanges(KeyRangeLocation.Builder builderForValue)
       The key ranges processed by the computation.
      repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;

    • addKeyRanges

      public ComputationTopology.Builder addKeyRanges(int index, KeyRangeLocation.Builder builderForValue)
       The key ranges processed by the computation.
      repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;

    • addAllKeyRanges

      public ComputationTopology.Builder addAllKeyRanges(Iterable<? extends KeyRangeLocation> values)
       The key ranges processed by the computation.
      repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;

    • clearKeyRanges

      public ComputationTopology.Builder clearKeyRanges()
       The key ranges processed by the computation.
      repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;

    • removeKeyRanges

      public ComputationTopology.Builder removeKeyRanges(int index)
       The key ranges processed by the computation.
      repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;

    • getKeyRangesBuilder

      public KeyRangeLocation.Builder getKeyRangesBuilder(int index)
       The key ranges processed by the computation.
      repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;

    • getKeyRangesOrBuilder

      public KeyRangeLocationOrBuilder getKeyRangesOrBuilder(int index)
       The key ranges processed by the computation.
      repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
      Specified by:
      getKeyRangesOrBuilder in interface ComputationTopologyOrBuilder

    • getKeyRangesOrBuilderList

      public List<? extends KeyRangeLocationOrBuilder> getKeyRangesOrBuilderList()
       The key ranges processed by the computation.
      repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;
      Specified by:
      getKeyRangesOrBuilderList in interface ComputationTopologyOrBuilder

    • addKeyRangesBuilder

      public KeyRangeLocation.Builder addKeyRangesBuilder()
       The key ranges processed by the computation.
      repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;

    • addKeyRangesBuilder

      public KeyRangeLocation.Builder addKeyRangesBuilder(int index)
       The key ranges processed by the computation.
      repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;

    • getKeyRangesBuilderList

      public List<KeyRangeLocation.Builder> getKeyRangesBuilderList()
       The key ranges processed by the computation.
      repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;

    • getInputsList

      public List<StreamLocation> getInputsList()
       The inputs to the computation.
      repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
      Specified by:
      getInputsList in interface ComputationTopologyOrBuilder

    • getInputsCount

      public int getInputsCount()
       The inputs to the computation.
      repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
      Specified by:
      getInputsCount in interface ComputationTopologyOrBuilder

    • getInputs

      public StreamLocation getInputs(int index)
       The inputs to the computation.
      repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
      Specified by:
      getInputs in interface ComputationTopologyOrBuilder

    • setInputs

      public ComputationTopology.Builder setInputs(int index, StreamLocation value)
       The inputs to the computation.
      repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;

    • setInputs

      public ComputationTopology.Builder setInputs(int index, StreamLocation.Builder builderForValue)
       The inputs to the computation.
      repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;

    • addInputs

      public ComputationTopology.Builder addInputs(StreamLocation value)
       The inputs to the computation.
      repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;

    • addInputs

      public ComputationTopology.Builder addInputs(int index, StreamLocation value)
       The inputs to the computation.
      repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;

    • addInputs

      public ComputationTopology.Builder addInputs(StreamLocation.Builder builderForValue)
       The inputs to the computation.
      repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;

    • addInputs

      public ComputationTopology.Builder addInputs(int index, StreamLocation.Builder builderForValue)
       The inputs to the computation.
      repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;

    • addAllInputs

      public ComputationTopology.Builder addAllInputs(Iterable<? extends StreamLocation> values)
       The inputs to the computation.
      repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;

    • clearInputs

      public ComputationTopology.Builder clearInputs()
       The inputs to the computation.
      repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;

    • removeInputs

      public ComputationTopology.Builder removeInputs(int index)
       The inputs to the computation.
      repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;

    • getInputsBuilder

      public StreamLocation.Builder getInputsBuilder(int index)
       The inputs to the computation.
      repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;

    • getInputsOrBuilder

      public StreamLocationOrBuilder getInputsOrBuilder(int index)
       The inputs to the computation.
      repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
      Specified by:
      getInputsOrBuilder in interface ComputationTopologyOrBuilder

    • getInputsOrBuilderList

      public List<? extends StreamLocationOrBuilder> getInputsOrBuilderList()
       The inputs to the computation.
      repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;
      Specified by:
      getInputsOrBuilderList in interface ComputationTopologyOrBuilder

    • addInputsBuilder

      public StreamLocation.Builder addInputsBuilder()
       The inputs to the computation.
      repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;

    • addInputsBuilder

      public StreamLocation.Builder addInputsBuilder(int index)
       The inputs to the computation.
      repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;

    • getInputsBuilderList

      public List<StreamLocation.Builder> getInputsBuilderList()
       The inputs to the computation.
      repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;

    • getOutputsList

      public List<StreamLocation> getOutputsList()
       The outputs from the computation.
      repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
      Specified by:
      getOutputsList in interface ComputationTopologyOrBuilder

    • getOutputsCount

      public int getOutputsCount()
       The outputs from the computation.
      repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
      Specified by:
      getOutputsCount in interface ComputationTopologyOrBuilder

    • getOutputs

      public StreamLocation getOutputs(int index)
       The outputs from the computation.
      repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
      Specified by:
      getOutputs in interface ComputationTopologyOrBuilder

    • setOutputs

      public ComputationTopology.Builder setOutputs(int index, StreamLocation value)
       The outputs from the computation.
      repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;

    • setOutputs

      public ComputationTopology.Builder setOutputs(int index, StreamLocation.Builder builderForValue)
       The outputs from the computation.
      repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;

    • addOutputs

      public ComputationTopology.Builder addOutputs(StreamLocation value)
       The outputs from the computation.
      repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;

    • addOutputs

      public ComputationTopology.Builder addOutputs(int index, StreamLocation value)
       The outputs from the computation.
      repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;

    • addOutputs

      public ComputationTopology.Builder addOutputs(StreamLocation.Builder builderForValue)
       The outputs from the computation.
      repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;

    • addOutputs

      public ComputationTopology.Builder addOutputs(int index, StreamLocation.Builder builderForValue)
       The outputs from the computation.
      repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;

    • addAllOutputs

      public ComputationTopology.Builder addAllOutputs(Iterable<? extends StreamLocation> values)
       The outputs from the computation.
      repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;

    • clearOutputs

      public ComputationTopology.Builder clearOutputs()
       The outputs from the computation.
      repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;

    • removeOutputs

      public ComputationTopology.Builder removeOutputs(int index)
       The outputs from the computation.
      repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;

    • getOutputsBuilder

      public StreamLocation.Builder getOutputsBuilder(int index)
       The outputs from the computation.
      repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;

    • getOutputsOrBuilder

      public StreamLocationOrBuilder getOutputsOrBuilder(int index)
       The outputs from the computation.
      repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
      Specified by:
      getOutputsOrBuilder in interface ComputationTopologyOrBuilder

    • getOutputsOrBuilderList

      public List<? extends StreamLocationOrBuilder> getOutputsOrBuilderList()
       The outputs from the computation.
      repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;
      Specified by:
      getOutputsOrBuilderList in interface ComputationTopologyOrBuilder

    • addOutputsBuilder

      public StreamLocation.Builder addOutputsBuilder()
       The outputs from the computation.
      repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;

    • addOutputsBuilder

      public StreamLocation.Builder addOutputsBuilder(int index)
       The outputs from the computation.
      repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;

    • getOutputsBuilderList

      public List<StreamLocation.Builder> getOutputsBuilderList()
       The outputs from the computation.
      repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;

    • getStateFamiliesList

      public List<StateFamilyConfig> getStateFamiliesList()
       The state family values.
      repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
      Specified by:
      getStateFamiliesList in interface ComputationTopologyOrBuilder

    • getStateFamiliesCount

      public int getStateFamiliesCount()
       The state family values.
      repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
      Specified by:
      getStateFamiliesCount in interface ComputationTopologyOrBuilder

    • getStateFamilies

      public StateFamilyConfig getStateFamilies(int index)
       The state family values.
      repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
      Specified by:
      getStateFamilies in interface ComputationTopologyOrBuilder

    • setStateFamilies

      public ComputationTopology.Builder setStateFamilies(int index, StateFamilyConfig value)
       The state family values.
      repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;

    • setStateFamilies

      public ComputationTopology.Builder setStateFamilies(int index, StateFamilyConfig.Builder builderForValue)
       The state family values.
      repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;

    • addStateFamilies

      public ComputationTopology.Builder addStateFamilies(StateFamilyConfig value)
       The state family values.
      repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;

    • addStateFamilies

      public ComputationTopology.Builder addStateFamilies(int index, StateFamilyConfig value)
       The state family values.
      repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;

    • addStateFamilies

      public ComputationTopology.Builder addStateFamilies(StateFamilyConfig.Builder builderForValue)
       The state family values.
      repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;

    • addStateFamilies

      public ComputationTopology.Builder addStateFamilies(int index, StateFamilyConfig.Builder builderForValue)
       The state family values.
      repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;

    • addAllStateFamilies

      public ComputationTopology.Builder addAllStateFamilies(Iterable<? extends StateFamilyConfig> values)
       The state family values.
      repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;

    • clearStateFamilies

      public ComputationTopology.Builder clearStateFamilies()
       The state family values.
      repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;

    • removeStateFamilies

      public ComputationTopology.Builder removeStateFamilies(int index)
       The state family values.
      repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;

    • getStateFamiliesBuilder

      public StateFamilyConfig.Builder getStateFamiliesBuilder(int index)
       The state family values.
      repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;

    • getStateFamiliesOrBuilder

      public StateFamilyConfigOrBuilder getStateFamiliesOrBuilder(int index)
       The state family values.
      repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
      Specified by:
      getStateFamiliesOrBuilder in interface ComputationTopologyOrBuilder

    • getStateFamiliesOrBuilderList

      public List<? extends StateFamilyConfigOrBuilder> getStateFamiliesOrBuilderList()
       The state family values.
      repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;
      Specified by:
      getStateFamiliesOrBuilderList in interface ComputationTopologyOrBuilder

    • addStateFamiliesBuilder

      public StateFamilyConfig.Builder addStateFamiliesBuilder()
       The state family values.
      repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;

    • addStateFamiliesBuilder

      public StateFamilyConfig.Builder addStateFamiliesBuilder(int index)
       The state family values.
      repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;

    • getStateFamiliesBuilderList

      public List<StateFamilyConfig.Builder> getStateFamiliesBuilderList()
       The state family values.
      repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;