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
Methods
__construct
Constructor.
| Parameters | |
|---|---|
| Name | Description |
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 | |
|---|---|
| Type | Description |
Google\Protobuf\Internal\RepeatedField | |
setComputations
The computations associated with a streaming Dataflow job.
| Parameter | |
|---|---|
| Name | Description |
var |
array<Google\Cloud\Dataflow\V1beta3\ComputationTopology>
|
| Returns | |
|---|---|
| Type | Description |
$this | |
getDataDiskAssignments
The disks assigned to a streaming Dataflow job.
| Returns | |
|---|---|
| Type | Description |
Google\Protobuf\Internal\RepeatedField | |
setDataDiskAssignments
The disks assigned to a streaming Dataflow job.
| Parameter | |
|---|---|
| Name | Description |
var |
array<Google\Cloud\Dataflow\V1beta3\DataDiskAssignment>
|
| Returns | |
|---|---|
| Type | Description |
$this | |
getUserStageToComputationNameMap
Maps user stage names to stable computation names.
| Returns | |
|---|---|
| Type | Description |
Google\Protobuf\Internal\MapField | |
setUserStageToComputationNameMap
Maps user stage names to stable computation names.
| Parameter | |
|---|---|
| Name | Description |
var |
array|Google\Protobuf\Internal\MapField
|
| Returns | |
|---|---|
| Type | Description |
$this | |
getForwardingKeyBits
The size (in bits) of keys that will be assigned to source messages.
| Returns | |
|---|---|
| Type | Description |
int | |
setForwardingKeyBits
The size (in bits) of keys that will be assigned to source messages.
| Parameter | |
|---|---|
| Name | Description |
var |
int
|
| Returns | |
|---|---|
| Type | Description |
$this | |
getPersistentStateVersion
Version number for persistent state.
| Returns | |
|---|---|
| Type | Description |
int | |
setPersistentStateVersion
Version number for persistent state.
| Parameter | |
|---|---|
| Name | Description |
var |
int
|
| Returns | |
|---|---|
| Type | Description |
$this | |