Some or all of the information on this page might not apply to Cloud de Confiance by S3NS. See Differences from Google Cloud for more details.

Class TopologyConfig.Builder (0.15.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)