DynamicSourceSplit
import type { DynamicSourceSplit } from "https://googleapis.deno.dev/v1/dataflow:v1b3.ts";
When a task splits using WorkItemStatus.dynamic_source_split, this message describes the two parts of the split relative to the description of the current task's input.
§Properties
§
primary?: DerivedSource
[src]Primary part (continued to be processed by worker). Specified relative to the previously-current source. Becomes current.
§
residual?: DerivedSource
[src]Residual part (returned to the pool of work). Specified relative to the previously-current source.