[GitHub] [flink-table-store] JingsongLi opened a new pull request #4: [FLINK-25628] Introduce RecordReader and related classes for table store

[GitBox <gi...@apache.org>]

JingsongLi opened a new pull request #4:
URL: https://github.com/apache/flink-table-store/pull/4


   - Introduce RecordReader interface: The reader that reads the batches of records. 
   - Introduce SortMergeReader: This reader is to read a list of `RecordReader`, which is already sorted by key and sequence number, and perform a sort merge algorithm. `KeyValue` with the same key will also be combined during sort merging.
   - Introduce ConcatRecordReader: This reader is to concatenate a list of `RecordReader` and read them sequentially. The input list is already sorted by key and sequence number, and the key intervals do not overlap each other.
   - Introduce FieldStats: Statistics for each field.
   - Introduce SstPathFactory: Factory which produces new Path for sst files.
   - Introduce SstFile and SstFileMeta: This SstFile includes several `KeyValue`, representing the changes inserted into the file storage.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink-table-store] JingsongLi merged pull request #4: [FLINK-25628] Introduce RecordReader and related classes for table store

[GitBox <gi...@apache.org>]

JingsongLi merged pull request #4:
URL: https://github.com/apache/flink-table-store/pull/4


   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org