Bulk Operation

FLINK-26116 Prevent users from changing bucket number

FLINK-26116 Add end to end tests for table store

FLINK-26116 Adjust default value of compaction and compress

FLINK-26116 Add version field to manifest entries

FLINK-26116 FileStoreCommitImpl#filterCommitted should exit when faced with expired files

FLINK-26116 Disable rolling file when writing level 0 sst files

FLINK-26116 Rename 'file.path' table option in table store to 'path'

FLINK-26116 Introduce filter predicate for 'LIKE'

FLINK-26116 Introduce snapshot.num-retained.min option

FLINK-26116 Reuse FileFormat instead of DecodingFormat/EncodingFormat to ensure thread safety.

FLINK-26116 Use '<format>.<option>' instead of 'file.<format>.<option>' in table properties of managed table

FLINK-26116 UniversalCompaction should pick by size ratio after picking by file num

FLINK-26116 Introduce parallelism setter for table store

FLINK-26116 Introduce auto type inference for filter push down

FLINK-26116 Finish projection push down for table store

FLINK-26116 Introduce snapshot latest and earliest hint files

FLINK-26116 PK constraint should include partition key

FLINK-26116 Remove change tracking in TableStore

FLINK-26116 Introduce flink-table-store-dist module for packaging

FLINK-26116 Delegate table planner dependencies with separate modules

FLINK-26116 FileStoreSourceSplitReader should deal with value count

FLINK-26116 Introduce table.path option for FileStoreOptions

FLINK-26116 Apply key & value filter in FileStoreScanImpl

FLINK-26116 Introduce StoreTableSource and StoreTableSink

FLINK-26116 Introduce TableStore API and refactor ITCases

FLINK-26116 Record hasNull and allNull instead of nullCount in FieldStats

FLINK-26116 FileStoreScan supports incremental consuming

FLINK-26116 Rename Accumulator to MergeFunction

FLINK-26116 Allow ManifestFile to write a list of ManifestFileMeta into multiple files if too many.

FLINK-26116 Overwrite commit kind should not be APPEND

FLINK-26116 Integrate log store to StoreSink

FLINK-26116 Add statistics collecting to sst files

FLINK-26116 Store log offsets in snapshot

FLINK-26116 Introduce ITCase for table store source and sink

FLINK-26116 Introduce a better expire strategy

FLINK-26116 Introduce manifest.merge-min-count in commit

FLINK-26116 Introduce implementation of ManagedTableFactory

FLINK-26116 Migrate StoreSink to Sink V2

FLINK-26116 Introduce log store

FLINK-26116 Introduce FileStoreRead

FLINK-26116 Support projection pushdown on keys and values in sst file readers

FLINK-26116 Implement FileStoreExpire

FLINK-26116 Implement overwrite in FileStoreScanImpl

FLINK-26116 Introduce Table Store Flink Source

FLINK-26116 Implement partition and bucket filter of FileStoreScanImpl

FLINK-26116 Introduce atomic commit

FLINK-26116 Introduce Table Store Flink Sink

FLINK-26116 Introduce interfaces between file-table-store and flink connector sink

FLINK-26116 Introduce Predicate to table store

FLINK-26116 Introduce MergeTree writer and reader for table store

FLINK-26116 Introduce CompactStrategy and CompactManager for table store

FLINK-26116 Introduce RecordReader and related classes for table store

FLINK-26116 Add basic structures of file store in table-store

FLINK-26116 Introduce FileFormat for table-store

FLINK-26116 Init flink-table-store repository