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

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

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

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

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

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

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

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() (deprecated)

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() (deprecated)

public Map<String,String> getUserStageToComputationNameMap()
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

internalGetMapFieldReflection(int number)

protected MapFieldReflectionAccessor internalGetMapFieldReflection(int number)
Parameter
Name Description
number int
Returns
Type Description
com.google.protobuf.MapFieldReflectionAccessor
Overrides
com.google.protobuf.GeneratedMessageV3.Builder.internalGetMapFieldReflection(int)

internalGetMutableMapFieldReflection(int number)

protected MapFieldReflectionAccessor internalGetMutableMapFieldReflection(int number)
Parameter
Name Description
number int
Returns
Type Description
com.google.protobuf.MapFieldReflectionAccessor
Overrides
com.google.protobuf.GeneratedMessageV3.Builder.internalGetMutableMapFieldReflection(int)

isInitialized()

public final boolean isInitialized()
Returns
Type Description
boolean
Overrides

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
Exceptions
Type Description
IOException

mergeFrom(Message other)

public TopologyConfig.Builder mergeFrom(Message other)
Parameter
Name Description
other Message
Returns
Type Description
TopologyConfig.Builder
Overrides

mergeUnknownFields(UnknownFieldSet unknownFields)

public final TopologyConfig.Builder mergeUnknownFields(UnknownFieldSet unknownFields)
Parameter
Name Description
unknownFields UnknownFieldSet
Returns
Type Description
TopologyConfig.Builder
Overrides

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

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

setUnknownFields(UnknownFieldSet unknownFields)

public final TopologyConfig.Builder setUnknownFields(UnknownFieldSet unknownFields)
Parameter
Name Description
unknownFields UnknownFieldSet
Returns
Type Description
TopologyConfig.Builder
Overrides