Class StreamingConfigTask

A task that carries configuration information for streaming computations.

Inheritance

object

StreamingConfigTask

Implements

IDirectResponseSchema

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Google.Apis.Dataflow.v1b3.Data

Assembly: Google.Apis.Dataflow.v1b3.dll

Syntax

public class StreamingConfigTask : IDirectResponseSchema

Properties

CommitStreamChunkSizeBytes

Chunk size for commit streams from the harness to windmill.

Declaration

[JsonProperty("commitStreamChunkSizeBytes")]
public virtual long? CommitStreamChunkSizeBytes { get; set; }

Property Value

Type	Description
long?

ETag

The ETag of the item.

Declaration

public virtual string ETag { get; set; }

Property Value

Type	Description
string

GetDataStreamChunkSizeBytes

Chunk size for get data streams from the harness to windmill.

Declaration

[JsonProperty("getDataStreamChunkSizeBytes")]
public virtual long? GetDataStreamChunkSizeBytes { get; set; }

Property Value

Type	Description
long?

MaxWorkItemCommitBytes

Maximum size for work item commit supported windmill storage layer.

Declaration

[JsonProperty("maxWorkItemCommitBytes")]
public virtual long? MaxWorkItemCommitBytes { get; set; }

Property Value

Type	Description
long?

OperationalLimits

Operational limits for the streaming job. Can be used by the worker to validate outputs sent to the backend.

Declaration

[JsonProperty("operationalLimits")]
public virtual StreamingOperationalLimits OperationalLimits { get; set; }

Property Value

Type	Description
StreamingOperationalLimits

StreamingComputationConfigs

Set of computation configuration information.

Declaration

[JsonProperty("streamingComputationConfigs")]
public virtual IList<StreamingComputationConfig> StreamingComputationConfigs { get; set; }

Property Value

Type	Description
IList<StreamingComputationConfig>

UserStepToStateFamilyNameMap

Map from user step names to state families.

Declaration

[JsonProperty("userStepToStateFamilyNameMap")]
public virtual IDictionary<string, string> UserStepToStateFamilyNameMap { get; set; }

Property Value

Type	Description
IDictionary<string, string>

UserWorkerRunnerV1Settings

Binary encoded proto to control runtime behavior of the java runner v1 user worker.

Declaration

[JsonProperty("userWorkerRunnerV1Settings")]
public virtual string UserWorkerRunnerV1Settings { get; set; }

Property Value

Type	Description
string

UserWorkerRunnerV2Settings

Binary encoded proto to control runtime behavior of the runner v2 user worker.

Declaration

[JsonProperty("userWorkerRunnerV2Settings")]
public virtual string UserWorkerRunnerV2Settings { get; set; }

Property Value

Type	Description
string

WindmillServiceEndpoint

If present, the worker must use this endpoint to communicate with Windmill Service dispatchers, otherwise the worker must continue to use whatever endpoint it had been using.

Declaration

[JsonProperty("windmillServiceEndpoint")]
public virtual string WindmillServiceEndpoint { get; set; }

Property Value

Type	Description
string

WindmillServicePort

If present, the worker must use this port to communicate with Windmill Service dispatchers. Only applicable when windmill_service_endpoint is specified.

Declaration

[JsonProperty("windmillServicePort")]
public virtual long? WindmillServicePort { get; set; }

Property Value

Type	Description
long?

Implements

IDirectResponseSchema