public sealed class TopologyConfig : IMessage<TopologyConfig>, IEquatable<TopologyConfig>, IDeepCloneable<TopologyConfig>, IBufferMessage, IMessageGlobal topology of the streaming Dataflow job, including all computations and their sharded locations.
Implements
IMessage<TopologyConfig>, IEquatable<TopologyConfig>, IDeepCloneable<TopologyConfig>, IBufferMessage, IMessageNamespace
Google.Cloud.Dataflow.V1Beta3Assembly
Google.Cloud.Dataflow.V1Beta3.dll
Constructors
TopologyConfig()
public TopologyConfig()TopologyConfig(TopologyConfig)
public TopologyConfig(TopologyConfig other)| Parameter | |
|---|---|
| Name | Description |
other |
TopologyConfig |
Properties
Computations
public RepeatedField<ComputationTopology> Computations { get; }The computations associated with a streaming Dataflow job.
| Property Value | |
|---|---|
| Type | Description |
RepeatedField<ComputationTopology> |
|
DataDiskAssignments
public RepeatedField<DataDiskAssignment> DataDiskAssignments { get; }The disks assigned to a streaming Dataflow job.
| Property Value | |
|---|---|
| Type | Description |
RepeatedField<DataDiskAssignment> |
|
ForwardingKeyBits
public int ForwardingKeyBits { get; set; }The size (in bits) of keys that will be assigned to source messages.
| Property Value | |
|---|---|
| Type | Description |
Int32 |
|
PersistentStateVersion
public int PersistentStateVersion { get; set; }Version number for persistent state.
| Property Value | |
|---|---|
| Type | Description |
Int32 |
|
UserStageToComputationNameMap
public MapField<string, string> UserStageToComputationNameMap { get; }Maps user stage names to stable computation names.
| Property Value | |
|---|---|
| Type | Description |
MapField<String, String> |
|