Google Cloud Dataflow V1beta3 Client - Class TopologyConfig (0.4.1)

Reference documentation and code samples for the Google Cloud Dataflow V1beta3 Client class TopologyConfig.

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

Generated from protobuf message google.dataflow.v1beta3.TopologyConfig

Namespace

Google \ Cloud \ Dataflow \ V1beta3

Methods

__construct

Constructor.

Parameters
NameDescription
data array

Optional. Data for populating the Message object.

↳ computations array<Google\Cloud\Dataflow\V1beta3\ComputationTopology>

The computations associated with a streaming Dataflow job.

↳ data_disk_assignments array<Google\Cloud\Dataflow\V1beta3\DataDiskAssignment>

The disks assigned to a streaming Dataflow job.

↳ user_stage_to_computation_name_map array|Google\Protobuf\Internal\MapField

Maps user stage names to stable computation names.

↳ forwarding_key_bits int

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

↳ persistent_state_version int

Version number for persistent state.

getComputations

The computations associated with a streaming Dataflow job.

Returns
TypeDescription
Google\Protobuf\Internal\RepeatedField

setComputations

The computations associated with a streaming Dataflow job.

Parameter
NameDescription
var array<Google\Cloud\Dataflow\V1beta3\ComputationTopology>
Returns
TypeDescription
$this

getDataDiskAssignments

The disks assigned to a streaming Dataflow job.

Returns
TypeDescription
Google\Protobuf\Internal\RepeatedField

setDataDiskAssignments

The disks assigned to a streaming Dataflow job.

Parameter
NameDescription
var array<Google\Cloud\Dataflow\V1beta3\DataDiskAssignment>
Returns
TypeDescription
$this

getUserStageToComputationNameMap

Maps user stage names to stable computation names.

Returns
TypeDescription
Google\Protobuf\Internal\MapField

setUserStageToComputationNameMap

Maps user stage names to stable computation names.

Parameter
NameDescription
var array|Google\Protobuf\Internal\MapField
Returns
TypeDescription
$this

getForwardingKeyBits

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

Returns
TypeDescription
int

setForwardingKeyBits

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

Parameter
NameDescription
var int
Returns
TypeDescription
$this

getPersistentStateVersion

Version number for persistent state.

Returns
TypeDescription
int

setPersistentStateVersion

Version number for persistent state.

Parameter
NameDescription
var int
Returns
TypeDescription
$this