Class ComputationTopology.Builder (0.39.0)

public static final class ComputationTopology.Builder extends GeneratedMessageV3.Builder<ComputationTopology.Builder> implements ComputationTopologyOrBuilder

All configuration data for a particular Computation.

Protobuf type google.dataflow.v1beta3.ComputationTopology

Static Methods

getDescriptor()

public static final Descriptors.Descriptor getDescriptor()
Returns
TypeDescription
Descriptor

Methods

addAllInputs(Iterable<? extends StreamLocation> values)

public ComputationTopology.Builder addAllInputs(Iterable<? extends StreamLocation> values)

The inputs to the computation.

repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;

Parameter
NameDescription
valuesIterable<? extends com.google.dataflow.v1beta3.StreamLocation>
Returns
TypeDescription
ComputationTopology.Builder

addAllKeyRanges(Iterable<? extends KeyRangeLocation> values)

public ComputationTopology.Builder addAllKeyRanges(Iterable<? extends KeyRangeLocation> values)

The key ranges processed by the computation.

repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;

Parameter
NameDescription
valuesIterable<? extends com.google.dataflow.v1beta3.KeyRangeLocation>
Returns
TypeDescription
ComputationTopology.Builder

addAllOutputs(Iterable<? extends StreamLocation> values)

public ComputationTopology.Builder addAllOutputs(Iterable<? extends StreamLocation> values)

The outputs from the computation.

repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;

Parameter
NameDescription
valuesIterable<? extends com.google.dataflow.v1beta3.StreamLocation>
Returns
TypeDescription
ComputationTopology.Builder

addAllStateFamilies(Iterable<? extends StateFamilyConfig> values)

public ComputationTopology.Builder addAllStateFamilies(Iterable<? extends StateFamilyConfig> values)

The state family values.

repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;

Parameter
NameDescription
valuesIterable<? extends com.google.dataflow.v1beta3.StateFamilyConfig>
Returns
TypeDescription
ComputationTopology.Builder

addInputs(StreamLocation value)

public ComputationTopology.Builder addInputs(StreamLocation value)

The inputs to the computation.

repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;

Parameter
NameDescription
valueStreamLocation
Returns
TypeDescription
ComputationTopology.Builder

addInputs(StreamLocation.Builder builderForValue)

public ComputationTopology.Builder addInputs(StreamLocation.Builder builderForValue)

The inputs to the computation.

repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;

Parameter
NameDescription
builderForValueStreamLocation.Builder
Returns
TypeDescription
ComputationTopology.Builder

addInputs(int index, StreamLocation value)

public ComputationTopology.Builder addInputs(int index, StreamLocation value)

The inputs to the computation.

repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;

Parameters
NameDescription
indexint
valueStreamLocation
Returns
TypeDescription
ComputationTopology.Builder

addInputs(int index, StreamLocation.Builder builderForValue)

public ComputationTopology.Builder addInputs(int index, StreamLocation.Builder builderForValue)

The inputs to the computation.

repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;

Parameters
NameDescription
indexint
builderForValueStreamLocation.Builder
Returns
TypeDescription
ComputationTopology.Builder

addInputsBuilder()

public StreamLocation.Builder addInputsBuilder()

The inputs to the computation.

repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;

Returns
TypeDescription
StreamLocation.Builder

addInputsBuilder(int index)

public StreamLocation.Builder addInputsBuilder(int index)

The inputs to the computation.

repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;

Parameter
NameDescription
indexint
Returns
TypeDescription
StreamLocation.Builder

addKeyRanges(KeyRangeLocation value)

public ComputationTopology.Builder addKeyRanges(KeyRangeLocation value)

The key ranges processed by the computation.

repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;

Parameter
NameDescription
valueKeyRangeLocation
Returns
TypeDescription
ComputationTopology.Builder

addKeyRanges(KeyRangeLocation.Builder builderForValue)

public ComputationTopology.Builder addKeyRanges(KeyRangeLocation.Builder builderForValue)

The key ranges processed by the computation.

repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;

Parameter
NameDescription
builderForValueKeyRangeLocation.Builder
Returns
TypeDescription
ComputationTopology.Builder

addKeyRanges(int index, KeyRangeLocation value)

public ComputationTopology.Builder addKeyRanges(int index, KeyRangeLocation value)

The key ranges processed by the computation.

repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;

Parameters
NameDescription
indexint
valueKeyRangeLocation
Returns
TypeDescription
ComputationTopology.Builder

addKeyRanges(int index, KeyRangeLocation.Builder builderForValue)

public ComputationTopology.Builder addKeyRanges(int index, KeyRangeLocation.Builder builderForValue)

The key ranges processed by the computation.

repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;

Parameters
NameDescription
indexint
builderForValueKeyRangeLocation.Builder
Returns
TypeDescription
ComputationTopology.Builder

addKeyRangesBuilder()

public KeyRangeLocation.Builder addKeyRangesBuilder()

The key ranges processed by the computation.

repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;

Returns
TypeDescription
KeyRangeLocation.Builder

addKeyRangesBuilder(int index)

public KeyRangeLocation.Builder addKeyRangesBuilder(int index)

The key ranges processed by the computation.

repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;

Parameter
NameDescription
indexint
Returns
TypeDescription
KeyRangeLocation.Builder

addOutputs(StreamLocation value)

public ComputationTopology.Builder addOutputs(StreamLocation value)

The outputs from the computation.

repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;

Parameter
NameDescription
valueStreamLocation
Returns
TypeDescription
ComputationTopology.Builder

addOutputs(StreamLocation.Builder builderForValue)

public ComputationTopology.Builder addOutputs(StreamLocation.Builder builderForValue)

The outputs from the computation.

repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;

Parameter
NameDescription
builderForValueStreamLocation.Builder
Returns
TypeDescription
ComputationTopology.Builder

addOutputs(int index, StreamLocation value)

public ComputationTopology.Builder addOutputs(int index, StreamLocation value)

The outputs from the computation.

repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;

Parameters
NameDescription
indexint
valueStreamLocation
Returns
TypeDescription
ComputationTopology.Builder

addOutputs(int index, StreamLocation.Builder builderForValue)

public ComputationTopology.Builder addOutputs(int index, StreamLocation.Builder builderForValue)

The outputs from the computation.

repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;

Parameters
NameDescription
indexint
builderForValueStreamLocation.Builder
Returns
TypeDescription
ComputationTopology.Builder

addOutputsBuilder()

public StreamLocation.Builder addOutputsBuilder()

The outputs from the computation.

repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;

Returns
TypeDescription
StreamLocation.Builder

addOutputsBuilder(int index)

public StreamLocation.Builder addOutputsBuilder(int index)

The outputs from the computation.

repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;

Parameter
NameDescription
indexint
Returns
TypeDescription
StreamLocation.Builder

addRepeatedField(Descriptors.FieldDescriptor field, Object value)

public ComputationTopology.Builder addRepeatedField(Descriptors.FieldDescriptor field, Object value)
Parameters
NameDescription
fieldFieldDescriptor
valueObject
Returns
TypeDescription
ComputationTopology.Builder
Overrides

addStateFamilies(StateFamilyConfig value)

public ComputationTopology.Builder addStateFamilies(StateFamilyConfig value)

The state family values.

repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;

Parameter
NameDescription
valueStateFamilyConfig
Returns
TypeDescription
ComputationTopology.Builder

addStateFamilies(StateFamilyConfig.Builder builderForValue)

public ComputationTopology.Builder addStateFamilies(StateFamilyConfig.Builder builderForValue)

The state family values.

repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;

Parameter
NameDescription
builderForValueStateFamilyConfig.Builder
Returns
TypeDescription
ComputationTopology.Builder

addStateFamilies(int index, StateFamilyConfig value)

public ComputationTopology.Builder addStateFamilies(int index, StateFamilyConfig value)

The state family values.

repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;

Parameters
NameDescription
indexint
valueStateFamilyConfig
Returns
TypeDescription
ComputationTopology.Builder

addStateFamilies(int index, StateFamilyConfig.Builder builderForValue)

public ComputationTopology.Builder addStateFamilies(int index, StateFamilyConfig.Builder builderForValue)

The state family values.

repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;

Parameters
NameDescription
indexint
builderForValueStateFamilyConfig.Builder
Returns
TypeDescription
ComputationTopology.Builder

addStateFamiliesBuilder()

public StateFamilyConfig.Builder addStateFamiliesBuilder()

The state family values.

repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;

Returns
TypeDescription
StateFamilyConfig.Builder

addStateFamiliesBuilder(int index)

public StateFamilyConfig.Builder addStateFamiliesBuilder(int index)

The state family values.

repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;

Parameter
NameDescription
indexint
Returns
TypeDescription
StateFamilyConfig.Builder

build()

public ComputationTopology build()
Returns
TypeDescription
ComputationTopology

buildPartial()

public ComputationTopology buildPartial()
Returns
TypeDescription
ComputationTopology

clear()

public ComputationTopology.Builder clear()
Returns
TypeDescription
ComputationTopology.Builder
Overrides

clearComputationId()

public ComputationTopology.Builder clearComputationId()

The ID of the computation.

string computation_id = 5;

Returns
TypeDescription
ComputationTopology.Builder

This builder for chaining.

clearField(Descriptors.FieldDescriptor field)

public ComputationTopology.Builder clearField(Descriptors.FieldDescriptor field)
Parameter
NameDescription
fieldFieldDescriptor
Returns
TypeDescription
ComputationTopology.Builder
Overrides

clearInputs()

public ComputationTopology.Builder clearInputs()

The inputs to the computation.

repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;

Returns
TypeDescription
ComputationTopology.Builder

clearKeyRanges()

public ComputationTopology.Builder clearKeyRanges()

The key ranges processed by the computation.

repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;

Returns
TypeDescription
ComputationTopology.Builder

clearOneof(Descriptors.OneofDescriptor oneof)

public ComputationTopology.Builder clearOneof(Descriptors.OneofDescriptor oneof)
Parameter
NameDescription
oneofOneofDescriptor
Returns
TypeDescription
ComputationTopology.Builder
Overrides

clearOutputs()

public ComputationTopology.Builder clearOutputs()

The outputs from the computation.

repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;

Returns
TypeDescription
ComputationTopology.Builder

clearStateFamilies()

public ComputationTopology.Builder clearStateFamilies()

The state family values.

repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;

Returns
TypeDescription
ComputationTopology.Builder

clearSystemStageName()

public ComputationTopology.Builder clearSystemStageName()

The system stage name.

string system_stage_name = 1;

Returns
TypeDescription
ComputationTopology.Builder

This builder for chaining.

clone()

public ComputationTopology.Builder clone()
Returns
TypeDescription
ComputationTopology.Builder
Overrides

getComputationId()

public String getComputationId()

The ID of the computation.

string computation_id = 5;

Returns
TypeDescription
String

The computationId.

getComputationIdBytes()

public ByteString getComputationIdBytes()

The ID of the computation.

string computation_id = 5;

Returns
TypeDescription
ByteString

The bytes for computationId.

getDefaultInstanceForType()

public ComputationTopology getDefaultInstanceForType()
Returns
TypeDescription
ComputationTopology

getDescriptorForType()

public Descriptors.Descriptor getDescriptorForType()
Returns
TypeDescription
Descriptor
Overrides

getInputs(int index)

public StreamLocation getInputs(int index)

The inputs to the computation.

repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;

Parameter
NameDescription
indexint
Returns
TypeDescription
StreamLocation

getInputsBuilder(int index)

public StreamLocation.Builder getInputsBuilder(int index)

The inputs to the computation.

repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;

Parameter
NameDescription
indexint
Returns
TypeDescription
StreamLocation.Builder

getInputsBuilderList()

public List<StreamLocation.Builder> getInputsBuilderList()

The inputs to the computation.

repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;

Returns
TypeDescription
List<Builder>

getInputsCount()

public int getInputsCount()

The inputs to the computation.

repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;

Returns
TypeDescription
int

getInputsList()

public List<StreamLocation> getInputsList()

The inputs to the computation.

repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;

Returns
TypeDescription
List<StreamLocation>

getInputsOrBuilder(int index)

public StreamLocationOrBuilder getInputsOrBuilder(int index)

The inputs to the computation.

repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;

Parameter
NameDescription
indexint
Returns
TypeDescription
StreamLocationOrBuilder

getInputsOrBuilderList()

public List<? extends StreamLocationOrBuilder> getInputsOrBuilderList()

The inputs to the computation.

repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;

Returns
TypeDescription
List<? extends com.google.dataflow.v1beta3.StreamLocationOrBuilder>

getKeyRanges(int index)

public KeyRangeLocation getKeyRanges(int index)

The key ranges processed by the computation.

repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;

Parameter
NameDescription
indexint
Returns
TypeDescription
KeyRangeLocation

getKeyRangesBuilder(int index)

public KeyRangeLocation.Builder getKeyRangesBuilder(int index)

The key ranges processed by the computation.

repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;

Parameter
NameDescription
indexint
Returns
TypeDescription
KeyRangeLocation.Builder

getKeyRangesBuilderList()

public List<KeyRangeLocation.Builder> getKeyRangesBuilderList()

The key ranges processed by the computation.

repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;

Returns
TypeDescription
List<Builder>

getKeyRangesCount()

public int getKeyRangesCount()

The key ranges processed by the computation.

repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;

Returns
TypeDescription
int

getKeyRangesList()

public List<KeyRangeLocation> getKeyRangesList()

The key ranges processed by the computation.

repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;

Returns
TypeDescription
List<KeyRangeLocation>

getKeyRangesOrBuilder(int index)

public KeyRangeLocationOrBuilder getKeyRangesOrBuilder(int index)

The key ranges processed by the computation.

repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;

Parameter
NameDescription
indexint
Returns
TypeDescription
KeyRangeLocationOrBuilder

getKeyRangesOrBuilderList()

public List<? extends KeyRangeLocationOrBuilder> getKeyRangesOrBuilderList()

The key ranges processed by the computation.

repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;

Returns
TypeDescription
List<? extends com.google.dataflow.v1beta3.KeyRangeLocationOrBuilder>

getOutputs(int index)

public StreamLocation getOutputs(int index)

The outputs from the computation.

repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;

Parameter
NameDescription
indexint
Returns
TypeDescription
StreamLocation

getOutputsBuilder(int index)

public StreamLocation.Builder getOutputsBuilder(int index)

The outputs from the computation.

repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;

Parameter
NameDescription
indexint
Returns
TypeDescription
StreamLocation.Builder

getOutputsBuilderList()

public List<StreamLocation.Builder> getOutputsBuilderList()

The outputs from the computation.

repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;

Returns
TypeDescription
List<Builder>

getOutputsCount()

public int getOutputsCount()

The outputs from the computation.

repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;

Returns
TypeDescription
int

getOutputsList()

public List<StreamLocation> getOutputsList()

The outputs from the computation.

repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;

Returns
TypeDescription
List<StreamLocation>

getOutputsOrBuilder(int index)

public StreamLocationOrBuilder getOutputsOrBuilder(int index)

The outputs from the computation.

repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;

Parameter
NameDescription
indexint
Returns
TypeDescription
StreamLocationOrBuilder

getOutputsOrBuilderList()

public List<? extends StreamLocationOrBuilder> getOutputsOrBuilderList()

The outputs from the computation.

repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;

Returns
TypeDescription
List<? extends com.google.dataflow.v1beta3.StreamLocationOrBuilder>

getStateFamilies(int index)

public StateFamilyConfig getStateFamilies(int index)

The state family values.

repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;

Parameter
NameDescription
indexint
Returns
TypeDescription
StateFamilyConfig

getStateFamiliesBuilder(int index)

public StateFamilyConfig.Builder getStateFamiliesBuilder(int index)

The state family values.

repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;

Parameter
NameDescription
indexint
Returns
TypeDescription
StateFamilyConfig.Builder

getStateFamiliesBuilderList()

public List<StateFamilyConfig.Builder> getStateFamiliesBuilderList()

The state family values.

repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;

Returns
TypeDescription
List<Builder>

getStateFamiliesCount()

public int getStateFamiliesCount()

The state family values.

repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;

Returns
TypeDescription
int

getStateFamiliesList()

public List<StateFamilyConfig> getStateFamiliesList()

The state family values.

repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;

Returns
TypeDescription
List<StateFamilyConfig>

getStateFamiliesOrBuilder(int index)

public StateFamilyConfigOrBuilder getStateFamiliesOrBuilder(int index)

The state family values.

repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;

Parameter
NameDescription
indexint
Returns
TypeDescription
StateFamilyConfigOrBuilder

getStateFamiliesOrBuilderList()

public List<? extends StateFamilyConfigOrBuilder> getStateFamiliesOrBuilderList()

The state family values.

repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;

Returns
TypeDescription
List<? extends com.google.dataflow.v1beta3.StateFamilyConfigOrBuilder>

getSystemStageName()

public String getSystemStageName()

The system stage name.

string system_stage_name = 1;

Returns
TypeDescription
String

The systemStageName.

getSystemStageNameBytes()

public ByteString getSystemStageNameBytes()

The system stage name.

string system_stage_name = 1;

Returns
TypeDescription
ByteString

The bytes for systemStageName.

internalGetFieldAccessorTable()

protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
Returns
TypeDescription
FieldAccessorTable
Overrides

isInitialized()

public final boolean isInitialized()
Returns
TypeDescription
boolean
Overrides

mergeFrom(ComputationTopology other)

public ComputationTopology.Builder mergeFrom(ComputationTopology other)
Parameter
NameDescription
otherComputationTopology
Returns
TypeDescription
ComputationTopology.Builder

mergeFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)

public ComputationTopology.Builder mergeFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)
Parameters
NameDescription
inputCodedInputStream
extensionRegistryExtensionRegistryLite
Returns
TypeDescription
ComputationTopology.Builder
Overrides
Exceptions
TypeDescription
IOException

mergeFrom(Message other)

public ComputationTopology.Builder mergeFrom(Message other)
Parameter
NameDescription
otherMessage
Returns
TypeDescription
ComputationTopology.Builder
Overrides

mergeUnknownFields(UnknownFieldSet unknownFields)

public final ComputationTopology.Builder mergeUnknownFields(UnknownFieldSet unknownFields)
Parameter
NameDescription
unknownFieldsUnknownFieldSet
Returns
TypeDescription
ComputationTopology.Builder
Overrides

removeInputs(int index)

public ComputationTopology.Builder removeInputs(int index)

The inputs to the computation.

repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;

Parameter
NameDescription
indexint
Returns
TypeDescription
ComputationTopology.Builder

removeKeyRanges(int index)

public ComputationTopology.Builder removeKeyRanges(int index)

The key ranges processed by the computation.

repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;

Parameter
NameDescription
indexint
Returns
TypeDescription
ComputationTopology.Builder

removeOutputs(int index)

public ComputationTopology.Builder removeOutputs(int index)

The outputs from the computation.

repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;

Parameter
NameDescription
indexint
Returns
TypeDescription
ComputationTopology.Builder

removeStateFamilies(int index)

public ComputationTopology.Builder removeStateFamilies(int index)

The state family values.

repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;

Parameter
NameDescription
indexint
Returns
TypeDescription
ComputationTopology.Builder

setComputationId(String value)

public ComputationTopology.Builder setComputationId(String value)

The ID of the computation.

string computation_id = 5;

Parameter
NameDescription
valueString

The computationId to set.

Returns
TypeDescription
ComputationTopology.Builder

This builder for chaining.

setComputationIdBytes(ByteString value)

public ComputationTopology.Builder setComputationIdBytes(ByteString value)

The ID of the computation.

string computation_id = 5;

Parameter
NameDescription
valueByteString

The bytes for computationId to set.

Returns
TypeDescription
ComputationTopology.Builder

This builder for chaining.

setField(Descriptors.FieldDescriptor field, Object value)

public ComputationTopology.Builder setField(Descriptors.FieldDescriptor field, Object value)
Parameters
NameDescription
fieldFieldDescriptor
valueObject
Returns
TypeDescription
ComputationTopology.Builder
Overrides

setInputs(int index, StreamLocation value)

public ComputationTopology.Builder setInputs(int index, StreamLocation value)

The inputs to the computation.

repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;

Parameters
NameDescription
indexint
valueStreamLocation
Returns
TypeDescription
ComputationTopology.Builder

setInputs(int index, StreamLocation.Builder builderForValue)

public ComputationTopology.Builder setInputs(int index, StreamLocation.Builder builderForValue)

The inputs to the computation.

repeated .google.dataflow.v1beta3.StreamLocation inputs = 3;

Parameters
NameDescription
indexint
builderForValueStreamLocation.Builder
Returns
TypeDescription
ComputationTopology.Builder

setKeyRanges(int index, KeyRangeLocation value)

public ComputationTopology.Builder setKeyRanges(int index, KeyRangeLocation value)

The key ranges processed by the computation.

repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;

Parameters
NameDescription
indexint
valueKeyRangeLocation
Returns
TypeDescription
ComputationTopology.Builder

setKeyRanges(int index, KeyRangeLocation.Builder builderForValue)

public ComputationTopology.Builder setKeyRanges(int index, KeyRangeLocation.Builder builderForValue)

The key ranges processed by the computation.

repeated .google.dataflow.v1beta3.KeyRangeLocation key_ranges = 2;

Parameters
NameDescription
indexint
builderForValueKeyRangeLocation.Builder
Returns
TypeDescription
ComputationTopology.Builder

setOutputs(int index, StreamLocation value)

public ComputationTopology.Builder setOutputs(int index, StreamLocation value)

The outputs from the computation.

repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;

Parameters
NameDescription
indexint
valueStreamLocation
Returns
TypeDescription
ComputationTopology.Builder

setOutputs(int index, StreamLocation.Builder builderForValue)

public ComputationTopology.Builder setOutputs(int index, StreamLocation.Builder builderForValue)

The outputs from the computation.

repeated .google.dataflow.v1beta3.StreamLocation outputs = 4;

Parameters
NameDescription
indexint
builderForValueStreamLocation.Builder
Returns
TypeDescription
ComputationTopology.Builder

setRepeatedField(Descriptors.FieldDescriptor field, int index, Object value)

public ComputationTopology.Builder setRepeatedField(Descriptors.FieldDescriptor field, int index, Object value)
Parameters
NameDescription
fieldFieldDescriptor
indexint
valueObject
Returns
TypeDescription
ComputationTopology.Builder
Overrides

setStateFamilies(int index, StateFamilyConfig value)

public ComputationTopology.Builder setStateFamilies(int index, StateFamilyConfig value)

The state family values.

repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;

Parameters
NameDescription
indexint
valueStateFamilyConfig
Returns
TypeDescription
ComputationTopology.Builder

setStateFamilies(int index, StateFamilyConfig.Builder builderForValue)

public ComputationTopology.Builder setStateFamilies(int index, StateFamilyConfig.Builder builderForValue)

The state family values.

repeated .google.dataflow.v1beta3.StateFamilyConfig state_families = 7;

Parameters
NameDescription
indexint
builderForValueStateFamilyConfig.Builder
Returns
TypeDescription
ComputationTopology.Builder

setSystemStageName(String value)

public ComputationTopology.Builder setSystemStageName(String value)

The system stage name.

string system_stage_name = 1;

Parameter
NameDescription
valueString

The systemStageName to set.

Returns
TypeDescription
ComputationTopology.Builder

This builder for chaining.

setSystemStageNameBytes(ByteString value)

public ComputationTopology.Builder setSystemStageNameBytes(ByteString value)

The system stage name.

string system_stage_name = 1;

Parameter
NameDescription
valueByteString

The bytes for systemStageName to set.

Returns
TypeDescription
ComputationTopology.Builder

This builder for chaining.

setUnknownFields(UnknownFieldSet unknownFields)

public final ComputationTopology.Builder setUnknownFields(UnknownFieldSet unknownFields)
Parameter
NameDescription
unknownFieldsUnknownFieldSet
Returns
TypeDescription
ComputationTopology.Builder
Overrides