Structsยง
- Build
Sink ๐Input Context - Pending
Sink ๐Barrier - Sink
Handler Input - A wrapper that merges data from a single upstream fragment and applies projection expressions.
Each
SinkHandlerInputrepresents one upstream fragment with its own merge executor and projection logic. - Upstream
Fragment Info - Information about an upstream fragment including its schema and projection expressions.
- Upstream
Sink ๐Barrier Manager - Upstream
Sink Union Executor UpstreamSinkUnionExecutormerges data from multiple upstream fragments, where each fragment has its own merge logic and projection expressions. This executor is specifically designed for sink operations that need to union data from different upstream sources.
Type Aliasesยง
- Boxed
Sink ๐Input - Processed
Message ๐Stream