Rui Fan created FLINK-39520:
-------------------------------

             Summary: Add spill file I/O and RecoveredBufferStore
                 Key: FLINK-39520
                 URL: https://issues.apache.org/jira/browse/FLINK-39520
             Project: Flink
          Issue Type: Sub-task
            Reporter: Rui Fan
            Assignee: Rui Fan


Introduces `SpillFileWriter` / `SpillFileReader` / `SpillEntry` for appending 
and reading recovery data on disk, and `RecoveredBufferStore` (+ 
`RecoveredBufferStoreImpl`, `EmptyRecoveredBufferStore`) as the per-channel 
staging layer that holds ready-to-consume buffers and tracks pending disk 
entries. These are the storage primitives consumed by OutputWriter and 
InputChannel in later commits.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to