Jingsong Lee created FLINK-28264:
------------------------------------
Summary: Refactor split and read in table store
Key: FLINK-28264
URL: https://issues.apache.org/jira/browse/FLINK-28264
Project: Flink
Issue Type: Improvement
Components: Table Store
Reporter: Jingsong Lee
Assignee: Jingsong Lee
Fix For: table-store-0.2.0
Refactor split and read, for better Hybrid reading. The full and incremental
read paths should be different, otherwise it is easy to get bugs.
* Add boolean isIncremental to Split
* Use Split in Flink Source Split and Hive Split
* FileStoreRead.createReader(Split)
* Create ConcatRecordReader or MergeTreeReader by Split.isIncremental
* Do key projection in KeyValueFileStoreRead.createReader
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
