Module upstream_sink_union

Structs§

BuildSinkInputContext 🔒
PendingSinkBarrier 🔒
SinkHandlerInput: A wrapper that merges data from a single upstream fragment and applies projection expressions. Each SinkHandlerInput represents one upstream fragment with its own merge executor and projection logic.
UpstreamFragmentInfo: Information about an upstream fragment including its schema and projection expressions.
UpstreamSinkBarrierManager 🔒
UpstreamSinkUnionExecutor: UpstreamSinkUnionExecutor merges 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.