Class TopologyConfig.Builder (0.41.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
TypeDescription
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
NameDescription
valuesIterable<? extends com.google.dataflow.v1beta3.ComputationTopology>
Returns
TypeDescription
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
NameDescription
valuesIterable<? extends com.google.dataflow.v1beta3.DataDiskAssignment>
Returns
TypeDescription
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
NameDescription
valueComputationTopology
Returns
TypeDescription
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
NameDescription
builderForValueComputationTopology.Builder
Returns
TypeDescription
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
NameDescription
indexint
valueComputationTopology
Returns
TypeDescription
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
NameDescription
indexint
builderForValueComputationTopology.Builder
Returns
TypeDescription
TopologyConfig.Builder

addComputationsBuilder()

public ComputationTopology.Builder addComputationsBuilder()

The computations associated with a streaming Dataflow job.

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

Returns
TypeDescription
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
NameDescription
indexint
Returns
TypeDescription
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
NameDescription
valueDataDiskAssignment
Returns
TypeDescription
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
NameDescription
builderForValueDataDiskAssignment.Builder
Returns
TypeDescription
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
NameDescription
indexint
valueDataDiskAssignment
Returns
TypeDescription
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
NameDescription
indexint
builderForValueDataDiskAssignment.Builder
Returns
TypeDescription
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
TypeDescription
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
NameDescription
indexint
Returns
TypeDescription
DataDiskAssignment.Builder

addRepeatedField(Descriptors.FieldDescriptor field, Object value)

public TopologyConfig.Builder addRepeatedField(Descriptors.FieldDescriptor field, Object value)
Parameters
NameDescription
fieldFieldDescriptor
valueObject
Returns
TypeDescription
TopologyConfig.Builder
Overrides

build()

public TopologyConfig build()
Returns
TypeDescription
TopologyConfig

buildPartial()

public TopologyConfig buildPartial()
Returns
TypeDescription
TopologyConfig

clear()

public TopologyConfig.Builder clear()
Returns
TypeDescription
TopologyConfig.Builder
Overrides

clearComputations()

public TopologyConfig.Builder clearComputations()

The computations associated with a streaming Dataflow job.

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

Returns
TypeDescription
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
TypeDescription
TopologyConfig.Builder

clearField(Descriptors.FieldDescriptor field)

public TopologyConfig.Builder clearField(Descriptors.FieldDescriptor field)
Parameter
NameDescription
fieldFieldDescriptor
Returns
TypeDescription
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
TypeDescription
TopologyConfig.Builder

This builder for chaining.

clearOneof(Descriptors.OneofDescriptor oneof)

public TopologyConfig.Builder clearOneof(Descriptors.OneofDescriptor oneof)
Parameter
NameDescription
oneofOneofDescriptor
Returns
TypeDescription
TopologyConfig.Builder
Overrides

clearPersistentStateVersion()

public TopologyConfig.Builder clearPersistentStateVersion()

Version number for persistent state.

int32 persistent_state_version = 5;

Returns
TypeDescription
TopologyConfig.Builder

This builder for chaining.

clearUserStageToComputationNameMap()

public TopologyConfig.Builder clearUserStageToComputationNameMap()
Returns
TypeDescription
TopologyConfig.Builder

clone()

public TopologyConfig.Builder clone()
Returns
TypeDescription
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
NameDescription
keyString
Returns
TypeDescription
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
NameDescription
indexint
Returns
TypeDescription
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
NameDescription
indexint
Returns
TypeDescription
ComputationTopology.Builder

getComputationsBuilderList()

public List<ComputationTopology.Builder> getComputationsBuilderList()

The computations associated with a streaming Dataflow job.

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

Returns
TypeDescription
List<Builder>

getComputationsCount()

public int getComputationsCount()

The computations associated with a streaming Dataflow job.

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

Returns
TypeDescription
int

getComputationsList()

public List<ComputationTopology> getComputationsList()

The computations associated with a streaming Dataflow job.

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

Returns
TypeDescription
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
NameDescription
indexint
Returns
TypeDescription
ComputationTopologyOrBuilder

getComputationsOrBuilderList()

public List<? extends ComputationTopologyOrBuilder> getComputationsOrBuilderList()

The computations associated with a streaming Dataflow job.

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

Returns
TypeDescription
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
NameDescription
indexint
Returns
TypeDescription
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
NameDescription
indexint
Returns
TypeDescription
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
TypeDescription
List<Builder>

getDataDiskAssignmentsCount()

public int getDataDiskAssignmentsCount()

The disks assigned to a streaming Dataflow job.

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

Returns
TypeDescription
int

getDataDiskAssignmentsList()

public List<DataDiskAssignment> getDataDiskAssignmentsList()

The disks assigned to a streaming Dataflow job.

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

Returns
TypeDescription
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
NameDescription
indexint
Returns
TypeDescription
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
TypeDescription
List<? extends com.google.dataflow.v1beta3.DataDiskAssignmentOrBuilder>

getDefaultInstanceForType()

public TopologyConfig getDefaultInstanceForType()
Returns
TypeDescription
TopologyConfig

getDescriptorForType()

public Descriptors.Descriptor getDescriptorForType()
Returns
TypeDescription
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
TypeDescription
int

The forwardingKeyBits.

getMutableUserStageToComputationNameMap() (deprecated)

public Map<String,String> getMutableUserStageToComputationNameMap()

Use alternate mutation accessors instead.

Returns
TypeDescription
Map<String,String>

getPersistentStateVersion()

public int getPersistentStateVersion()

Version number for persistent state.

int32 persistent_state_version = 5;

Returns
TypeDescription
int

The persistentStateVersion.

getUserStageToComputationNameMap() (deprecated)

public Map<String,String> getUserStageToComputationNameMap()
Returns
TypeDescription
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
TypeDescription
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
TypeDescription
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
NameDescription
keyString
defaultValueString
Returns
TypeDescription
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
NameDescription
keyString
Returns
TypeDescription
String

internalGetFieldAccessorTable()

protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
Returns
TypeDescription
FieldAccessorTable
Overrides

internalGetMapFieldReflection(int number)

protected MapFieldReflectionAccessor internalGetMapFieldReflection(int number)
Parameter
NameDescription
numberint
Returns
TypeDescription
com.google.protobuf.MapFieldReflectionAccessor
Overrides
com.google.protobuf.GeneratedMessageV3.Builder.internalGetMapFieldReflection(int)

internalGetMutableMapFieldReflection(int number)

protected MapFieldReflectionAccessor internalGetMutableMapFieldReflection(int number)
Parameter
NameDescription
numberint
Returns
TypeDescription
com.google.protobuf.MapFieldReflectionAccessor
Overrides
com.google.protobuf.GeneratedMessageV3.Builder.internalGetMutableMapFieldReflection(int)

isInitialized()

public final boolean isInitialized()
Returns
TypeDescription
boolean
Overrides

mergeFrom(TopologyConfig other)

public TopologyConfig.Builder mergeFrom(TopologyConfig other)
Parameter
NameDescription
otherTopologyConfig
Returns
TypeDescription
TopologyConfig.Builder

mergeFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)

public TopologyConfig.Builder mergeFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)
Parameters
NameDescription
inputCodedInputStream
extensionRegistryExtensionRegistryLite
Returns
TypeDescription
TopologyConfig.Builder
Overrides
Exceptions
TypeDescription
IOException

mergeFrom(Message other)

public TopologyConfig.Builder mergeFrom(Message other)
Parameter
NameDescription
otherMessage
Returns
TypeDescription
TopologyConfig.Builder
Overrides

mergeUnknownFields(UnknownFieldSet unknownFields)

public final TopologyConfig.Builder mergeUnknownFields(UnknownFieldSet unknownFields)
Parameter
NameDescription
unknownFieldsUnknownFieldSet
Returns
TypeDescription
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
NameDescription
valuesMap<String,String>
Returns
TypeDescription
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
NameDescription
keyString
valueString
Returns
TypeDescription
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
NameDescription
indexint
Returns
TypeDescription
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
NameDescription
indexint
Returns
TypeDescription
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
NameDescription
keyString
Returns
TypeDescription
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
NameDescription
indexint
valueComputationTopology
Returns
TypeDescription
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
NameDescription
indexint
builderForValueComputationTopology.Builder
Returns
TypeDescription
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
NameDescription
indexint
valueDataDiskAssignment
Returns
TypeDescription
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
NameDescription
indexint
builderForValueDataDiskAssignment.Builder
Returns
TypeDescription
TopologyConfig.Builder

setField(Descriptors.FieldDescriptor field, Object value)

public TopologyConfig.Builder setField(Descriptors.FieldDescriptor field, Object value)
Parameters
NameDescription
fieldFieldDescriptor
valueObject
Returns
TypeDescription
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
NameDescription
valueint

The forwardingKeyBits to set.

Returns
TypeDescription
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
NameDescription
valueint

The persistentStateVersion to set.

Returns
TypeDescription
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
NameDescription
fieldFieldDescriptor
indexint
valueObject
Returns
TypeDescription
TopologyConfig.Builder
Overrides

setUnknownFields(UnknownFieldSet unknownFields)

public final TopologyConfig.Builder setUnknownFields(UnknownFieldSet unknownFields)
Parameter
NameDescription
unknownFieldsUnknownFieldSet
Returns
TypeDescription
TopologyConfig.Builder
Overrides