Class ComputationTopology.Builder (0.58.0)

Version 0.58.0

• 0.59.0 (latest)
• 0.58.0
• 0.57.0
• 0.56.0
• 0.55.0
• 0.53.0
• 0.52.0
• 0.51.0
• 0.50.0
• 0.49.0
• 0.48.0
• 0.47.0
• 0.46.0
• 0.45.0
• 0.44.0
• 0.43.0
• 0.41.0
• 0.40.0
• 0.39.0
• 0.38.0
• 0.37.0
• 0.36.0
• 0.35.0
• 0.34.0
• 0.33.0
• 0.32.0
• 0.31.0
• 0.28.0
• 0.27.0
• 0.26.0
• 0.25.0
• 0.24.0
• 0.23.0
• 0.22.0
• 0.21.0
• 0.20.0
• 0.19.0
• 0.18.0
• 0.17.0
• 0.16.0
• 0.15.0
• 0.13.0
• 0.12.0
• 0.11.0
• 0.10.0
• 0.9.0
• 0.8.0
• 0.5.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

Inheritance

Object > AbstractMessageLite.Builder<MessageType,BuilderType> > AbstractMessage.Builder<BuilderType> > GeneratedMessageV3.Builder > ComputationTopology.Builder

Implements

ComputationTopologyOrBuilder

Inherited Members

AbstractMessage.Builder.findInitializationErrors()

AbstractMessage.Builder.getInitializationErrorString()

AbstractMessage.Builder.internalMergeFrom(AbstractMessageLite)

AbstractMessage.Builder.mergeFrom(byte[])

AbstractMessage.Builder.mergeFrom(byte[],ExtensionRegistryLite)

AbstractMessage.Builder.mergeFrom(byte[],int,int)

AbstractMessage.Builder.mergeFrom(byte[],int,int,ExtensionRegistryLite)

AbstractMessage.Builder.mergeFrom(ByteString)

AbstractMessage.Builder.mergeFrom(ByteString,ExtensionRegistryLite)

AbstractMessage.Builder.mergeFrom(CodedInputStream)

AbstractMessage.Builder.mergeFrom(CodedInputStream,ExtensionRegistryLite)

AbstractMessage.Builder.mergeFrom(Message)

AbstractMessage.Builder.mergeFrom(InputStream)

AbstractMessage.Builder.mergeFrom(InputStream,ExtensionRegistryLite)

AbstractMessage.Builder.newUninitializedMessageException(Message)

AbstractMessage.Builder.toString()

AbstractMessageLite.Builder.<T>addAll(Iterable<T>,Collection<? super T>)

AbstractMessageLite.Builder.<T>addAll(Iterable<T>,List<? super T>)

AbstractMessageLite.Builder.internalMergeFrom(MessageType)

AbstractMessageLite.Builder.mergeDelimitedFrom(InputStream)

AbstractMessageLite.Builder.mergeDelimitedFrom(InputStream,ExtensionRegistryLite)

AbstractMessageLite.Builder.mergeFrom(MessageLite)

AbstractMessageLite.Builder.newUninitializedMessageException(MessageLite)

GeneratedMessageV3.Builder.addRepeatedField(Descriptors.FieldDescriptor,Object)

GeneratedMessageV3.Builder.clear()

GeneratedMessageV3.Builder.clearField(Descriptors.FieldDescriptor)

GeneratedMessageV3.Builder.clearOneof(Descriptors.OneofDescriptor)

GeneratedMessageV3.Builder.clone()

GeneratedMessageV3.Builder.getAllFields()

GeneratedMessageV3.Builder.getDescriptorForType()

GeneratedMessageV3.Builder.getField(Descriptors.FieldDescriptor)

GeneratedMessageV3.Builder.getFieldBuilder(Descriptors.FieldDescriptor)

GeneratedMessageV3.Builder.getOneofFieldDescriptor(Descriptors.OneofDescriptor)

GeneratedMessageV3.Builder.getParentForChildren()

GeneratedMessageV3.Builder.getRepeatedField(Descriptors.FieldDescriptor,int)

GeneratedMessageV3.Builder.getRepeatedFieldBuilder(Descriptors.FieldDescriptor,int)

GeneratedMessageV3.Builder.getRepeatedFieldCount(Descriptors.FieldDescriptor)

com.google.protobuf.GeneratedMessageV3.Builder.getUnknownFieldSetBuilder()

GeneratedMessageV3.Builder.getUnknownFields()

GeneratedMessageV3.Builder.hasField(Descriptors.FieldDescriptor)

GeneratedMessageV3.Builder.hasOneof(Descriptors.OneofDescriptor)

GeneratedMessageV3.Builder.internalGetFieldAccessorTable()

GeneratedMessageV3.Builder.internalGetMapField(int)

com.google.protobuf.GeneratedMessageV3.Builder.internalGetMapFieldReflection(int)

GeneratedMessageV3.Builder.internalGetMutableMapField(int)

com.google.protobuf.GeneratedMessageV3.Builder.internalGetMutableMapFieldReflection(int)

GeneratedMessageV3.Builder.isClean()

GeneratedMessageV3.Builder.isInitialized()

GeneratedMessageV3.Builder.markClean()

GeneratedMessageV3.Builder.mergeUnknownFields(UnknownFieldSet)

com.google.protobuf.GeneratedMessageV3.Builder.mergeUnknownLengthDelimitedField(int,com.google.protobuf.ByteString)

com.google.protobuf.GeneratedMessageV3.Builder.mergeUnknownVarintField(int,int)

GeneratedMessageV3.Builder.newBuilderForField(Descriptors.FieldDescriptor)

GeneratedMessageV3.Builder.onBuilt()

GeneratedMessageV3.Builder.onChanged()

com.google.protobuf.GeneratedMessageV3.Builder.parseUnknownField(com.google.protobuf.CodedInputStream,com.google.protobuf.ExtensionRegistryLite,int)

GeneratedMessageV3.Builder.setField(Descriptors.FieldDescriptor,Object)

GeneratedMessageV3.Builder.setRepeatedField(Descriptors.FieldDescriptor,int,Object)

com.google.protobuf.GeneratedMessageV3.Builder.setUnknownFieldSetBuilder(com.google.protobuf.UnknownFieldSet.Builder)

GeneratedMessageV3.Builder.setUnknownFields(UnknownFieldSet)

GeneratedMessageV3.Builder.setUnknownFieldsProto3(UnknownFieldSet)

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Static Methods

getDescriptor()

public static final Descriptors.Descriptor getDescriptor()

Returns
Type	Description
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
Name	Description
values	Iterable<? extends com.google.dataflow.v1beta3.StreamLocation>

Returns
Type	Description
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
Name	Description
values	Iterable<? extends com.google.dataflow.v1beta3.KeyRangeLocation>

Returns
Type	Description
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
Name	Description
values	Iterable<? extends com.google.dataflow.v1beta3.StreamLocation>

Returns
Type	Description
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
Name	Description
values	Iterable<? extends com.google.dataflow.v1beta3.StateFamilyConfig>

Returns
Type	Description
ComputationTopology.Builder

addInputs(StreamLocation value)

public ComputationTopology.Builder addInputs(StreamLocation value)

The inputs to the computation.

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

Parameter
Name	Description
value	StreamLocation

Returns
Type	Description
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
Name	Description
builderForValue	StreamLocation.Builder

Returns
Type	Description
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
Name	Description
index	int
value	StreamLocation

Returns
Type	Description
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
Name	Description
index	int
builderForValue	StreamLocation.Builder

Returns
Type	Description
ComputationTopology.Builder

addInputsBuilder()

public StreamLocation.Builder addInputsBuilder()

The inputs to the computation.

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

Returns
Type	Description
StreamLocation.Builder

addInputsBuilder(int index)

public StreamLocation.Builder addInputsBuilder(int index)

The inputs to the computation.

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

Parameter
Name	Description
index	int

Returns
Type	Description
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
Name	Description
value	KeyRangeLocation

Returns
Type	Description
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
Name	Description
builderForValue	KeyRangeLocation.Builder

Returns
Type	Description
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
Name	Description
index	int
value	KeyRangeLocation

Returns
Type	Description
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
Name	Description
index	int
builderForValue	KeyRangeLocation.Builder

Returns
Type	Description
ComputationTopology.Builder

addKeyRangesBuilder()

public KeyRangeLocation.Builder addKeyRangesBuilder()

The key ranges processed by the computation.

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

Returns
Type	Description
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
Name	Description
index	int

Returns
Type	Description
KeyRangeLocation.Builder

addOutputs(StreamLocation value)

public ComputationTopology.Builder addOutputs(StreamLocation value)

The outputs from the computation.

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

Parameter
Name	Description
value	StreamLocation

Returns
Type	Description
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
Name	Description
builderForValue	StreamLocation.Builder

Returns
Type	Description
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
Name	Description
index	int
value	StreamLocation

Returns
Type	Description
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
Name	Description
index	int
builderForValue	StreamLocation.Builder

Returns
Type	Description
ComputationTopology.Builder

addOutputsBuilder()

public StreamLocation.Builder addOutputsBuilder()

The outputs from the computation.

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

Returns
Type	Description
StreamLocation.Builder

addOutputsBuilder(int index)

public StreamLocation.Builder addOutputsBuilder(int index)

The outputs from the computation.

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

Parameter
Name	Description
index	int

Returns
Type	Description
StreamLocation.Builder

addRepeatedField(Descriptors.FieldDescriptor field, Object value)

public ComputationTopology.Builder addRepeatedField(Descriptors.FieldDescriptor field, Object value)

Parameters
Name	Description
field	FieldDescriptor
value	Object

Returns
Type	Description
ComputationTopology.Builder

Overrides

GeneratedMessageV3.Builder<BuilderType>.addRepeatedField(Descriptors.FieldDescriptor field, Object value)

addStateFamilies(StateFamilyConfig value)

public ComputationTopology.Builder addStateFamilies(StateFamilyConfig value)

The state family values.

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

Parameter
Name	Description
value	StateFamilyConfig

Returns
Type	Description
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
Name	Description
builderForValue	StateFamilyConfig.Builder

Returns
Type	Description
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
Name	Description
index	int
value	StateFamilyConfig

Returns
Type	Description
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
Name	Description
index	int
builderForValue	StateFamilyConfig.Builder

Returns
Type	Description
ComputationTopology.Builder

addStateFamiliesBuilder()

public StateFamilyConfig.Builder addStateFamiliesBuilder()

The state family values.

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

Returns
Type	Description
StateFamilyConfig.Builder

addStateFamiliesBuilder(int index)

public StateFamilyConfig.Builder addStateFamiliesBuilder(int index)

The state family values.

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

Parameter
Name	Description
index	int

Returns
Type	Description
StateFamilyConfig.Builder

build()

public ComputationTopology build()

Returns
Type	Description
ComputationTopology

buildPartial()

public ComputationTopology buildPartial()

Returns
Type	Description
ComputationTopology

clear()

public ComputationTopology.Builder clear()

Returns
Type	Description
ComputationTopology.Builder

Overrides

GeneratedMessageV3.Builder<BuilderType>.clear()

clearComputationId()

public ComputationTopology.Builder clearComputationId()

The ID of the computation.

string computation_id = 5;

Returns
Type	Description
ComputationTopology.Builder	This builder for chaining.

clearField(Descriptors.FieldDescriptor field)

public ComputationTopology.Builder clearField(Descriptors.FieldDescriptor field)

Parameter
Name	Description
field	FieldDescriptor

Returns
Type	Description
ComputationTopology.Builder

Overrides

GeneratedMessageV3.Builder<BuilderType>.clearField(Descriptors.FieldDescriptor field)

clearInputs()

public ComputationTopology.Builder clearInputs()

The inputs to the computation.

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

Returns
Type	Description
ComputationTopology.Builder

clearKeyRanges()

public ComputationTopology.Builder clearKeyRanges()

The key ranges processed by the computation.

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

Returns
Type	Description
ComputationTopology.Builder

clearOneof(Descriptors.OneofDescriptor oneof)

public ComputationTopology.Builder clearOneof(Descriptors.OneofDescriptor oneof)

Parameter
Name	Description
oneof	OneofDescriptor

Returns
Type	Description
ComputationTopology.Builder

Overrides

GeneratedMessageV3.Builder<BuilderType>.clearOneof(Descriptors.OneofDescriptor oneof)

clearOutputs()

public ComputationTopology.Builder clearOutputs()

The outputs from the computation.

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

Returns
Type	Description
ComputationTopology.Builder

clearStateFamilies()

public ComputationTopology.Builder clearStateFamilies()

The state family values.

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

Returns
Type	Description
ComputationTopology.Builder

clearSystemStageName()

public ComputationTopology.Builder clearSystemStageName()

The system stage name.

string system_stage_name = 1;

Returns
Type	Description
ComputationTopology.Builder	This builder for chaining.

clone()

public ComputationTopology.Builder clone()

Returns
Type	Description
ComputationTopology.Builder

Overrides

GeneratedMessageV3.Builder<BuilderType>.clone()

getComputationId()

public String getComputationId()

The ID of the computation.

string computation_id = 5;

Returns
Type	Description
String	The computationId.

getComputationIdBytes()

public ByteString getComputationIdBytes()

The ID of the computation.

string computation_id = 5;

Returns
Type	Description
ByteString	The bytes for computationId.

getDefaultInstanceForType()

public ComputationTopology getDefaultInstanceForType()

Returns
Type	Description
ComputationTopology

getDescriptorForType()

public Descriptors.Descriptor getDescriptorForType()

Returns
Type	Description
Descriptor

Overrides

GeneratedMessageV3.Builder<BuilderType>.getDescriptorForType()

getInputs(int index)

public StreamLocation getInputs(int index)

The inputs to the computation.

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

Parameter
Name	Description
index	int

Returns
Type	Description
StreamLocation

getInputsBuilder(int index)

public StreamLocation.Builder getInputsBuilder(int index)

The inputs to the computation.

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

Parameter
Name	Description
index	int

Returns
Type	Description
StreamLocation.Builder

getInputsBuilderList()

public List<StreamLocation.Builder> getInputsBuilderList()

The inputs to the computation.

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

Returns
Type	Description
List<Builder>

getInputsCount()

public int getInputsCount()

The inputs to the computation.

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

Returns
Type	Description
int

getInputsList()

public List<StreamLocation> getInputsList()

The inputs to the computation.

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

Returns
Type	Description
List<StreamLocation>

getInputsOrBuilder(int index)

public StreamLocationOrBuilder getInputsOrBuilder(int index)

The inputs to the computation.

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

Parameter
Name	Description
index	int

Returns
Type	Description
StreamLocationOrBuilder

getInputsOrBuilderList()

public List<? extends StreamLocationOrBuilder> getInputsOrBuilderList()

The inputs to the computation.

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

Returns
Type	Description
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
Name	Description
index	int

Returns
Type	Description
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
Name	Description
index	int

Returns
Type	Description
KeyRangeLocation.Builder

getKeyRangesBuilderList()

public List<KeyRangeLocation.Builder> getKeyRangesBuilderList()

The key ranges processed by the computation.

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

Returns
Type	Description
List<Builder>

getKeyRangesCount()

public int getKeyRangesCount()

The key ranges processed by the computation.

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

Returns
Type	Description
int

getKeyRangesList()

public List<KeyRangeLocation> getKeyRangesList()

The key ranges processed by the computation.

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

Returns
Type	Description
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
Name	Description
index	int

Returns
Type	Description
KeyRangeLocationOrBuilder

getKeyRangesOrBuilderList()

public List<? extends KeyRangeLocationOrBuilder> getKeyRangesOrBuilderList()

The key ranges processed by the computation.

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

Returns
Type	Description
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
Name	Description
index	int

Returns
Type	Description
StreamLocation

getOutputsBuilder(int index)

public StreamLocation.Builder getOutputsBuilder(int index)

The outputs from the computation.

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

Parameter
Name	Description
index	int

Returns
Type	Description
StreamLocation.Builder

getOutputsBuilderList()

public List<StreamLocation.Builder> getOutputsBuilderList()

The outputs from the computation.

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

Returns
Type	Description
List<Builder>

getOutputsCount()

public int getOutputsCount()

The outputs from the computation.

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

Returns
Type	Description
int

getOutputsList()

public List<StreamLocation> getOutputsList()

The outputs from the computation.

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

Returns
Type	Description
List<StreamLocation>

getOutputsOrBuilder(int index)

public StreamLocationOrBuilder getOutputsOrBuilder(int index)

The outputs from the computation.

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

Parameter
Name	Description
index	int

Returns
Type	Description
StreamLocationOrBuilder

getOutputsOrBuilderList()

public List<? extends StreamLocationOrBuilder> getOutputsOrBuilderList()

The outputs from the computation.

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

Returns
Type	Description
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
Name	Description
index	int

Returns
Type	Description
StateFamilyConfig

getStateFamiliesBuilder(int index)

public StateFamilyConfig.Builder getStateFamiliesBuilder(int index)

The state family values.

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

Parameter
Name	Description
index	int

Returns
Type	Description
StateFamilyConfig.Builder

getStateFamiliesBuilderList()

public List<StateFamilyConfig.Builder> getStateFamiliesBuilderList()

The state family values.

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

Returns
Type	Description
List<Builder>

getStateFamiliesCount()

public int getStateFamiliesCount()

The state family values.

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

Returns
Type	Description
int

getStateFamiliesList()

public List<StateFamilyConfig> getStateFamiliesList()

The state family values.

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

Returns
Type	Description
List<StateFamilyConfig>

getStateFamiliesOrBuilder(int index)

public StateFamilyConfigOrBuilder getStateFamiliesOrBuilder(int index)

The state family values.

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

Parameter
Name	Description
index	int

Returns
Type	Description
StateFamilyConfigOrBuilder

getStateFamiliesOrBuilderList()

public List<? extends StateFamilyConfigOrBuilder> getStateFamiliesOrBuilderList()

The state family values.

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

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

getSystemStageName()

public String getSystemStageName()

The system stage name.

string system_stage_name = 1;

Returns
Type	Description
String	The systemStageName.

getSystemStageNameBytes()

public ByteString getSystemStageNameBytes()

The system stage name.

string system_stage_name = 1;

Returns
Type	Description
ByteString	The bytes for systemStageName.

internalGetFieldAccessorTable()

protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()

Returns
Type	Description
FieldAccessorTable

Overrides

GeneratedMessageV3.Builder<BuilderType>.internalGetFieldAccessorTable()

isInitialized()

public final boolean isInitialized()

Returns
Type	Description
boolean

Overrides

GeneratedMessageV3.Builder<BuilderType>.isInitialized()

mergeFrom(ComputationTopology other)

public ComputationTopology.Builder mergeFrom(ComputationTopology other)

Parameter
Name	Description
other	ComputationTopology

Returns
Type	Description
ComputationTopology.Builder

mergeFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)

public ComputationTopology.Builder mergeFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)

Parameters
Name	Description
input	CodedInputStream
extensionRegistry	ExtensionRegistryLite

Returns
Type	Description
ComputationTopology.Builder

Overrides

AbstractMessage.Builder<BuilderType>.mergeFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)

Exceptions
Type	Description
IOException

mergeFrom(Message other)

public ComputationTopology.Builder mergeFrom(Message other)

Parameter
Name	Description
other	Message

Returns
Type	Description
ComputationTopology.Builder

Overrides

AbstractMessage.Builder<BuilderType>.mergeFrom(Message other)

mergeUnknownFields(UnknownFieldSet unknownFields)

public final ComputationTopology.Builder mergeUnknownFields(UnknownFieldSet unknownFields)

Parameter
Name	Description
unknownFields	UnknownFieldSet

Returns
Type	Description
ComputationTopology.Builder

Overrides

GeneratedMessageV3.Builder<BuilderType>.mergeUnknownFields(UnknownFieldSet unknownFields)

removeInputs(int index)

public ComputationTopology.Builder removeInputs(int index)

The inputs to the computation.

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

Parameter
Name	Description
index	int

Returns
Type	Description
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
Name	Description
index	int

Returns
Type	Description
ComputationTopology.Builder

removeOutputs(int index)

public ComputationTopology.Builder removeOutputs(int index)

The outputs from the computation.

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

Parameter
Name	Description
index	int

Returns
Type	Description
ComputationTopology.Builder

removeStateFamilies(int index)

public ComputationTopology.Builder removeStateFamilies(int index)

The state family values.

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

Parameter
Name	Description
index	int

Returns
Type	Description
ComputationTopology.Builder

setComputationId(String value)

public ComputationTopology.Builder setComputationId(String value)

The ID of the computation.

string computation_id = 5;

Parameter
Name	Description
value	String The computationId to set.

Returns
Type	Description
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
Name	Description
value	ByteString The bytes for computationId to set.

Returns
Type	Description
ComputationTopology.Builder	This builder for chaining.

setField(Descriptors.FieldDescriptor field, Object value)

public ComputationTopology.Builder setField(Descriptors.FieldDescriptor field, Object value)

Parameters
Name	Description
field	FieldDescriptor
value	Object

Returns
Type	Description
ComputationTopology.Builder

Overrides

GeneratedMessageV3.Builder<BuilderType>.setField(Descriptors.FieldDescriptor field, Object value)

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
Name	Description
index	int
value	StreamLocation

Returns
Type	Description
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
Name	Description
index	int
builderForValue	StreamLocation.Builder

Returns
Type	Description
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
Name	Description
index	int
value	KeyRangeLocation

Returns
Type	Description
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
Name	Description
index	int
builderForValue	KeyRangeLocation.Builder

Returns
Type	Description
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
Name	Description
index	int
value	StreamLocation

Returns
Type	Description
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
Name	Description
index	int
builderForValue	StreamLocation.Builder

Returns
Type	Description
ComputationTopology.Builder

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

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

Parameters
Name	Description
field	FieldDescriptor
index	int
value	Object

Returns
Type	Description
ComputationTopology.Builder

Overrides

GeneratedMessageV3.Builder<BuilderType>.setRepeatedField(Descriptors.FieldDescriptor field, int index, Object value)

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
Name	Description
index	int
value	StateFamilyConfig

Returns
Type	Description
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
Name	Description
index	int
builderForValue	StateFamilyConfig.Builder

Returns
Type	Description
ComputationTopology.Builder

setSystemStageName(String value)

public ComputationTopology.Builder setSystemStageName(String value)

The system stage name.

string system_stage_name = 1;

Parameter
Name	Description
value	String The systemStageName to set.

Returns
Type	Description
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
Name	Description
value	ByteString The bytes for systemStageName to set.

Returns
Type	Description
ComputationTopology.Builder	This builder for chaining.

setUnknownFields(UnknownFieldSet unknownFields)

public final ComputationTopology.Builder setUnknownFields(UnknownFieldSet unknownFields)

Parameter
Name	Description
unknownFields	UnknownFieldSet

Returns
Type	Description
ComputationTopology.Builder

Overrides

GeneratedMessageV3.Builder<BuilderType>.setUnknownFields(UnknownFieldSet unknownFields)