Rui Fan created FLINK-39521:
-------------------------------
Summary: Add OutputWriter for post-filter record dispatch
Key: FLINK-39521
URL: https://issues.apache.org/jira/browse/FLINK-39521
Project: Flink
Issue Type: Sub-task
Reporter: Rui Fan
Introduces `OutputWriter` / `OutputWriterImpl`, which routes post-filter bytes
into one of three paths per `write()`: fill the active Network Buffer (P1),
spill to disk when no buffer is available (P2), or eagerly drain disk back into
a buffer when one frees up (P3). `flush()` seals the active buffer; `close()`
performs a blocking drain to exhaust remaining disk data;
`checkpointPendingEntries()` streams all queued disk entries into a checkpoint
in one sequential pass.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
