Class TopologyConfig.Builder (0.10.0)

Stay organized with collections Save and categorize content based on your preferences.
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