StreamingConfigTask class
A task that carries configuration information for streaming computations.
Constructors
-
StreamingConfigTask({String? commitStreamChunkSizeBytes, String? getDataStreamChunkSizeBytes, String? maxWorkItemCommitBytes, List<
StreamingComputationConfig> ? streamingComputationConfigs, Map<String, String> ? userStepToStateFamilyNameMap, String? windmillServiceEndpoint, String? windmillServicePort}) - StreamingConfigTask.fromJson(Map json_)
Properties
- commitStreamChunkSizeBytes ↔ String?
-
Chunk size for commit streams from the harness to windmill.
getter/setter pair
- getDataStreamChunkSizeBytes ↔ String?
-
Chunk size for get data streams from the harness to windmill.
getter/setter pair
- hashCode → int
-
The hash code for this object.
no setterinherited
- maxWorkItemCommitBytes ↔ String?
-
Maximum size for work item commit supported windmill storage layer.
getter/setter pair
- runtimeType → Type
-
A representation of the runtime type of the object.
no setterinherited
-
streamingComputationConfigs
↔ List<
StreamingComputationConfig> ? -
Set of computation configuration information.
getter/setter pair
-
userStepToStateFamilyNameMap
↔ Map<
String, String> ? -
Map from user step names to state families.
getter/setter pair
- windmillServiceEndpoint ↔ String?
-
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.
getter/setter pair
- windmillServicePort ↔ String?
-
If present, the worker must use this port to communicate with Windmill
Service dispatchers.
getter/setter pair
Methods
-
noSuchMethod(
Invocation invocation) → dynamic -
Invoked when a nonexistent method or property is accessed.
inherited
-
toJson(
) → Map< String, dynamic> -
toString(
) → String -
A string representation of this object.
inherited
Operators
-
operator ==(
Object other) → bool -
The equality operator.
inherited