Class TopologyConfig.Builder (0.8.0)

Version 0.8.0

• 0.45.0 (latest)
• 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 TopologyConfig.Builder extends GeneratedMessageV3.Builder<TopologyConfig.Builder> implements TopologyConfigOrBuilder

Global topology of the streaming Dataflow job, including all computations and their sharded locations.

Protobuf type google.dataflow.v1beta3.TopologyConfig

Inheritance

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

Implements

TopologyConfigOrBuilder

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)

GeneratedMessageV3.Builder.internalGetMutableMapField(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

addAllComputations(Iterable<? extends ComputationTopology> values)

public TopologyConfig.Builder addAllComputations(Iterable<? extends ComputationTopology> values)

The computations associated with a streaming Dataflow job.

repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

Parameter

Name	Description
values	Iterable<? extends com.google.dataflow.v1beta3.ComputationTopology>

Returns

Type	Description
TopologyConfig.Builder

addAllDataDiskAssignments(Iterable<? extends DataDiskAssignment> values)

public TopologyConfig.Builder addAllDataDiskAssignments(Iterable<? extends DataDiskAssignment> values)

The disks assigned to a streaming Dataflow job.

repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

Parameter

Name	Description
values	Iterable<? extends com.google.dataflow.v1beta3.DataDiskAssignment>

Returns

Type	Description
TopologyConfig.Builder

addComputations(ComputationTopology value)

public TopologyConfig.Builder addComputations(ComputationTopology value)

The computations associated with a streaming Dataflow job.

repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

Parameter

Name	Description
value	ComputationTopology

Returns

Type	Description
TopologyConfig.Builder

addComputations(ComputationTopology.Builder builderForValue)

public TopologyConfig.Builder addComputations(ComputationTopology.Builder builderForValue)

The computations associated with a streaming Dataflow job.

repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

Parameter

Name	Description
builderForValue	ComputationTopology.Builder

Returns

Type	Description
TopologyConfig.Builder

addComputations(int index, ComputationTopology value)

public TopologyConfig.Builder addComputations(int index, ComputationTopology value)

The computations associated with a streaming Dataflow job.

repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

Parameters

Name	Description
index	int
value	ComputationTopology

Returns

Type	Description
TopologyConfig.Builder

addComputations(int index, ComputationTopology.Builder builderForValue)

public TopologyConfig.Builder addComputations(int index, ComputationTopology.Builder builderForValue)

The computations associated with a streaming Dataflow job.

repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

Parameters

Name	Description
index	int
builderForValue	ComputationTopology.Builder

Returns

Type	Description
TopologyConfig.Builder

addComputationsBuilder()

public ComputationTopology.Builder addComputationsBuilder()

The computations associated with a streaming Dataflow job.

repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

Returns

Type	Description
ComputationTopology.Builder

addComputationsBuilder(int index)

public ComputationTopology.Builder addComputationsBuilder(int index)

The computations associated with a streaming Dataflow job.

repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

Parameter

Name	Description
index	int

Returns

Type	Description
ComputationTopology.Builder

addDataDiskAssignments(DataDiskAssignment value)

public TopologyConfig.Builder addDataDiskAssignments(DataDiskAssignment value)

The disks assigned to a streaming Dataflow job.

repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

Parameter

Name	Description
value	DataDiskAssignment

Returns

Type	Description
TopologyConfig.Builder

addDataDiskAssignments(DataDiskAssignment.Builder builderForValue)

public TopologyConfig.Builder addDataDiskAssignments(DataDiskAssignment.Builder builderForValue)

The disks assigned to a streaming Dataflow job.

repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

Parameter

Name	Description
builderForValue	DataDiskAssignment.Builder

Returns

Type	Description
TopologyConfig.Builder

addDataDiskAssignments(int index, DataDiskAssignment value)

public TopologyConfig.Builder addDataDiskAssignments(int index, DataDiskAssignment value)

The disks assigned to a streaming Dataflow job.

repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

Parameters

Name	Description
index	int
value	DataDiskAssignment

Returns

Type	Description
TopologyConfig.Builder

addDataDiskAssignments(int index, DataDiskAssignment.Builder builderForValue)

public TopologyConfig.Builder addDataDiskAssignments(int index, DataDiskAssignment.Builder builderForValue)

The disks assigned to a streaming Dataflow job.

repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

Parameters

Name	Description
index	int
builderForValue	DataDiskAssignment.Builder

Returns

Type	Description
TopologyConfig.Builder

addDataDiskAssignmentsBuilder()

public DataDiskAssignment.Builder addDataDiskAssignmentsBuilder()

The disks assigned to a streaming Dataflow job.

repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

Returns

Type	Description
DataDiskAssignment.Builder

addDataDiskAssignmentsBuilder(int index)

public DataDiskAssignment.Builder addDataDiskAssignmentsBuilder(int index)

The disks assigned to a streaming Dataflow job.

repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

Parameter

Name	Description
index	int

Returns

Type	Description
DataDiskAssignment.Builder

addRepeatedField(Descriptors.FieldDescriptor field, Object value)

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

Parameters

Name	Description
field	FieldDescriptor
value	Object

Returns

Type	Description
TopologyConfig.Builder

Overrides

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

build()

public TopologyConfig build()

Returns

Type	Description
TopologyConfig

buildPartial()

public TopologyConfig buildPartial()

Returns

Type	Description
TopologyConfig

clear()

public TopologyConfig.Builder clear()

Returns

Type	Description
TopologyConfig.Builder

Overrides

GeneratedMessageV3.Builder<BuilderType>.clear()

clearComputations()

public TopologyConfig.Builder clearComputations()

The computations associated with a streaming Dataflow job.

repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

Returns

Type	Description
TopologyConfig.Builder

clearDataDiskAssignments()

public TopologyConfig.Builder clearDataDiskAssignments()

The disks assigned to a streaming Dataflow job.

repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

Returns

Type	Description
TopologyConfig.Builder

clearField(Descriptors.FieldDescriptor field)

public TopologyConfig.Builder clearField(Descriptors.FieldDescriptor field)

Parameter

Name	Description
field	FieldDescriptor

Returns

Type	Description
TopologyConfig.Builder

Overrides

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

clearForwardingKeyBits()

public TopologyConfig.Builder clearForwardingKeyBits()

The size (in bits) of keys that will be assigned to source messages.

int32 forwarding_key_bits = 4;

Returns

Type	Description
TopologyConfig.Builder	This builder for chaining.

clearOneof(Descriptors.OneofDescriptor oneof)

public TopologyConfig.Builder clearOneof(Descriptors.OneofDescriptor oneof)

Parameter

Name	Description
oneof	OneofDescriptor

Returns

Type	Description
TopologyConfig.Builder

Overrides

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

clearPersistentStateVersion()

public TopologyConfig.Builder clearPersistentStateVersion()

Version number for persistent state.

int32 persistent_state_version = 5;

Returns

Type	Description
TopologyConfig.Builder	This builder for chaining.

clearUserStageToComputationNameMap()

public TopologyConfig.Builder clearUserStageToComputationNameMap()

Returns

Type	Description
TopologyConfig.Builder

clone()

public TopologyConfig.Builder clone()

Returns

Type	Description
TopologyConfig.Builder

Overrides

GeneratedMessageV3.Builder<BuilderType>.clone()

containsUserStageToComputationNameMap(String key)

public boolean containsUserStageToComputationNameMap(String key)

Maps user stage names to stable computation names.

map<string, string> user_stage_to_computation_name_map = 3;

Parameter

Name	Description
key	String

Returns

Type	Description
boolean

getComputations(int index)

public ComputationTopology getComputations(int index)

The computations associated with a streaming Dataflow job.

repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

Parameter

Name	Description
index	int

Returns

Type	Description
ComputationTopology

getComputationsBuilder(int index)

public ComputationTopology.Builder getComputationsBuilder(int index)

The computations associated with a streaming Dataflow job.

repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

Parameter

Name	Description
index	int

Returns

Type	Description
ComputationTopology.Builder

getComputationsBuilderList()

public List<ComputationTopology.Builder> getComputationsBuilderList()

The computations associated with a streaming Dataflow job.

repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

Returns

Type	Description
List<Builder>

getComputationsCount()

public int getComputationsCount()

The computations associated with a streaming Dataflow job.

repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

Returns

Type	Description
int

getComputationsList()

public List<ComputationTopology> getComputationsList()

The computations associated with a streaming Dataflow job.

repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

Returns

Type	Description
List<ComputationTopology>

getComputationsOrBuilder(int index)

public ComputationTopologyOrBuilder getComputationsOrBuilder(int index)

The computations associated with a streaming Dataflow job.

repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

Parameter

Name	Description
index	int

Returns

Type	Description
ComputationTopologyOrBuilder

getComputationsOrBuilderList()

public List<? extends ComputationTopologyOrBuilder> getComputationsOrBuilderList()

The computations associated with a streaming Dataflow job.

repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

Returns

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

getDataDiskAssignments(int index)

public DataDiskAssignment getDataDiskAssignments(int index)

The disks assigned to a streaming Dataflow job.

repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

Parameter

Name	Description
index	int

Returns

Type	Description
DataDiskAssignment

getDataDiskAssignmentsBuilder(int index)

public DataDiskAssignment.Builder getDataDiskAssignmentsBuilder(int index)

The disks assigned to a streaming Dataflow job.

repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

Parameter

Name	Description
index	int

Returns

Type	Description
DataDiskAssignment.Builder

getDataDiskAssignmentsBuilderList()

public List<DataDiskAssignment.Builder> getDataDiskAssignmentsBuilderList()

The disks assigned to a streaming Dataflow job.

repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

Returns

Type	Description
List<Builder>

getDataDiskAssignmentsCount()

public int getDataDiskAssignmentsCount()

The disks assigned to a streaming Dataflow job.

repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

Returns

Type	Description
int

getDataDiskAssignmentsList()

public List<DataDiskAssignment> getDataDiskAssignmentsList()

The disks assigned to a streaming Dataflow job.

repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

Returns

Type	Description
List<DataDiskAssignment>

getDataDiskAssignmentsOrBuilder(int index)

public DataDiskAssignmentOrBuilder getDataDiskAssignmentsOrBuilder(int index)

The disks assigned to a streaming Dataflow job.

repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

Parameter

Name	Description
index	int

Returns

Type	Description
DataDiskAssignmentOrBuilder

getDataDiskAssignmentsOrBuilderList()

public List<? extends DataDiskAssignmentOrBuilder> getDataDiskAssignmentsOrBuilderList()

The disks assigned to a streaming Dataflow job.

repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

Returns

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

getDefaultInstanceForType()

public TopologyConfig getDefaultInstanceForType()

Returns

Type	Description
TopologyConfig

getDescriptorForType()

public Descriptors.Descriptor getDescriptorForType()

Returns

Type	Description
Descriptor

Overrides

GeneratedMessageV3.Builder<BuilderType>.getDescriptorForType()

getForwardingKeyBits()

public int getForwardingKeyBits()

The size (in bits) of keys that will be assigned to source messages.

int32 forwarding_key_bits = 4;

Returns

Type	Description
int	The forwardingKeyBits.

getMutableUserStageToComputationNameMap()

public Map<String,String> getMutableUserStageToComputationNameMap()

Use alternate mutation accessors instead.

Returns

Type	Description
Map<String,String>

getPersistentStateVersion()

public int getPersistentStateVersion()

Version number for persistent state.

int32 persistent_state_version = 5;

Returns

Type	Description
int	The persistentStateVersion.

getUserStageToComputationNameMap()

public Map<String,String> getUserStageToComputationNameMap()

Use #getUserStageToComputationNameMapMap() instead.

Returns

Type	Description
Map<String,String>

getUserStageToComputationNameMapCount()

public int getUserStageToComputationNameMapCount()

Maps user stage names to stable computation names.

map<string, string> user_stage_to_computation_name_map = 3;

Returns

Type	Description
int

getUserStageToComputationNameMapMap()

public Map<String,String> getUserStageToComputationNameMapMap()

Maps user stage names to stable computation names.

map<string, string> user_stage_to_computation_name_map = 3;

Returns

Type	Description
Map<String,String>

getUserStageToComputationNameMapOrDefault(String key, String defaultValue)

public String getUserStageToComputationNameMapOrDefault(String key, String defaultValue)

Maps user stage names to stable computation names.

map<string, string> user_stage_to_computation_name_map = 3;

Parameters

Name	Description
key	String
defaultValue	String

Returns

Type	Description
String

getUserStageToComputationNameMapOrThrow(String key)

public String getUserStageToComputationNameMapOrThrow(String key)

Maps user stage names to stable computation names.

map<string, string> user_stage_to_computation_name_map = 3;

Parameter

Name	Description
key	String

Returns

Type	Description
String

internalGetFieldAccessorTable()

protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()

Returns

Type	Description
FieldAccessorTable

Overrides

GeneratedMessageV3.Builder<BuilderType>.internalGetFieldAccessorTable()

internalGetMapField(int number)

protected MapField internalGetMapField(int number)

Parameter

Name	Description
number	int

Returns

Type	Description
MapField

Overrides

GeneratedMessageV3.Builder<BuilderType>.internalGetMapField(int fieldNumber)

internalGetMutableMapField(int number)

protected MapField internalGetMutableMapField(int number)

Parameter

Name	Description
number	int

Returns

Type	Description
MapField

Overrides

GeneratedMessageV3.Builder<BuilderType>.internalGetMutableMapField(int fieldNumber)

isInitialized()

public final boolean isInitialized()

Returns

Type	Description
boolean

Overrides

GeneratedMessageV3.Builder<BuilderType>.isInitialized()

mergeFrom(TopologyConfig other)

public TopologyConfig.Builder mergeFrom(TopologyConfig other)

Parameter

Name	Description
other	TopologyConfig

Returns

Type	Description
TopologyConfig.Builder

mergeFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)

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

Parameters

Name	Description
input	CodedInputStream
extensionRegistry	ExtensionRegistryLite

Returns

Type	Description
TopologyConfig.Builder

Overrides

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

Exceptions

Type	Description
IOException

mergeFrom(Message other)

public TopologyConfig.Builder mergeFrom(Message other)

Parameter

Name	Description
other	Message

Returns

Type	Description
TopologyConfig.Builder

Overrides

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

mergeUnknownFields(UnknownFieldSet unknownFields)

public final TopologyConfig.Builder mergeUnknownFields(UnknownFieldSet unknownFields)

Parameter

Name	Description
unknownFields	UnknownFieldSet

Returns

Type	Description
TopologyConfig.Builder

Overrides

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

putAllUserStageToComputationNameMap(Map<String,String> values)

public TopologyConfig.Builder putAllUserStageToComputationNameMap(Map<String,String> values)

Maps user stage names to stable computation names.

map<string, string> user_stage_to_computation_name_map = 3;

Parameter

Name	Description
values	Map<String,String>

Returns

Type	Description
TopologyConfig.Builder

putUserStageToComputationNameMap(String key, String value)

public TopologyConfig.Builder putUserStageToComputationNameMap(String key, String value)

Maps user stage names to stable computation names.

map<string, string> user_stage_to_computation_name_map = 3;

Parameters

Name	Description
key	String
value	String

Returns

Type	Description
TopologyConfig.Builder

removeComputations(int index)

public TopologyConfig.Builder removeComputations(int index)

The computations associated with a streaming Dataflow job.

repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

Parameter

Name	Description
index	int

Returns

Type	Description
TopologyConfig.Builder

removeDataDiskAssignments(int index)

public TopologyConfig.Builder removeDataDiskAssignments(int index)

The disks assigned to a streaming Dataflow job.

repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

Parameter

Name	Description
index	int

Returns

Type	Description
TopologyConfig.Builder

removeUserStageToComputationNameMap(String key)

public TopologyConfig.Builder removeUserStageToComputationNameMap(String key)

Maps user stage names to stable computation names.

map<string, string> user_stage_to_computation_name_map = 3;

Parameter

Name	Description
key	String

Returns

Type	Description
TopologyConfig.Builder

setComputations(int index, ComputationTopology value)

public TopologyConfig.Builder setComputations(int index, ComputationTopology value)

The computations associated with a streaming Dataflow job.

repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

Parameters

Name	Description
index	int
value	ComputationTopology

Returns

Type	Description
TopologyConfig.Builder

setComputations(int index, ComputationTopology.Builder builderForValue)

public TopologyConfig.Builder setComputations(int index, ComputationTopology.Builder builderForValue)

The computations associated with a streaming Dataflow job.

repeated .google.dataflow.v1beta3.ComputationTopology computations = 1;

Parameters

Name	Description
index	int
builderForValue	ComputationTopology.Builder

Returns

Type	Description
TopologyConfig.Builder

setDataDiskAssignments(int index, DataDiskAssignment value)

public TopologyConfig.Builder setDataDiskAssignments(int index, DataDiskAssignment value)

The disks assigned to a streaming Dataflow job.

repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

Parameters

Name	Description
index	int
value	DataDiskAssignment

Returns

Type	Description
TopologyConfig.Builder

setDataDiskAssignments(int index, DataDiskAssignment.Builder builderForValue)

public TopologyConfig.Builder setDataDiskAssignments(int index, DataDiskAssignment.Builder builderForValue)

The disks assigned to a streaming Dataflow job.

repeated .google.dataflow.v1beta3.DataDiskAssignment data_disk_assignments = 2;

Parameters

Name	Description
index	int
builderForValue	DataDiskAssignment.Builder

Returns

Type	Description
TopologyConfig.Builder

setField(Descriptors.FieldDescriptor field, Object value)

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

Parameters

Name	Description
field	FieldDescriptor
value	Object

Returns

Type	Description
TopologyConfig.Builder

Overrides

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

setForwardingKeyBits(int value)

public TopologyConfig.Builder setForwardingKeyBits(int value)

The size (in bits) of keys that will be assigned to source messages.

int32 forwarding_key_bits = 4;

Parameter

Name	Description
value	int The forwardingKeyBits to set.

Returns

Type	Description
TopologyConfig.Builder	This builder for chaining.

setPersistentStateVersion(int value)

public TopologyConfig.Builder setPersistentStateVersion(int value)

Version number for persistent state.

int32 persistent_state_version = 5;

Parameter

Name	Description
value	int The persistentStateVersion to set.

Returns

Type	Description
TopologyConfig.Builder	This builder for chaining.

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

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

Parameters

Name	Description
field	FieldDescriptor
index	int
value	Object

Returns

Type	Description
TopologyConfig.Builder

Overrides

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

setUnknownFields(UnknownFieldSet unknownFields)

public final TopologyConfig.Builder setUnknownFields(UnknownFieldSet unknownFields)

Parameter

Name	Description
unknownFields	UnknownFieldSet

Returns

Type	Description
TopologyConfig.Builder

Overrides

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