Class ComputationTopology.Builder (0.10.0)

Stay organized with collections Save and categorize content based on your preferences.
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)