flink-table-store.git
22 hours ago[FLINK-27629] Fix NullPointerException in NotEqual predicate master
tsreaper [Mon, 16 May 2022 06:58:01 +0000 (14:58 +0800)] 
[FLINK-27629] Fix NullPointerException in NotEqual predicate

This closes #122

4 days ago[FLINK-27558] Introduce a new optional option for TableStoreFactory to represent...
Jane Chan [Fri, 13 May 2022 04:23:21 +0000 (12:23 +0800)] 
[FLINK-27558] Introduce a new optional option for TableStoreFactory to represent planned manifest entries

This closes #116

4 days ago[FLINK-27589] Fix incorrect implementation of TableStoreDateObjectInspector
tsreaper [Thu, 12 May 2022 11:07:11 +0000 (19:07 +0800)] 
[FLINK-27589] Fix incorrect implementation of TableStoreDateObjectInspector

This closes #120

4 days ago[FLINK-27347] Support reading external table store table in Hive
tsreaper [Thu, 12 May 2022 08:44:15 +0000 (16:44 +0800)] 
[FLINK-27347] Support reading external table store table in Hive

This closes #113

5 days ago[FLINK-27372] Make DataFileMeta and ManifestFileMeta schemaless
Jingsong Lee [Thu, 12 May 2022 03:36:52 +0000 (11:36 +0800)] 
[FLINK-27372] Make DataFileMeta and ManifestFileMeta schemaless

This closes #107

5 days ago[FLINK-27546] Add append only writer which implements the RecordWriter interface
openinx [Wed, 11 May 2022 08:41:22 +0000 (16:41 +0800)] 
[FLINK-27546] Add append only writer which implements the RecordWriter interface

This closes #115

6 days ago[FLINK-27542] E2e docker image should not occupy host machine ports as tests may...
tsreaper [Wed, 11 May 2022 03:22:47 +0000 (11:22 +0800)] 
[FLINK-27542] E2e docker image should not occupy host machine ports as tests may run in parallel

This closes #118

6 days ago[FLINK-27540] Let FileStoreSource accept pre-planned manifest entries
Jane Chan [Tue, 10 May 2022 12:26:12 +0000 (20:26 +0800)] 
[FLINK-27540] Let FileStoreSource accept pre-planned manifest entries

This closes #111

7 days ago[FLINK-27542] Refactor E2eTestBase with docker compose
tsreaper [Mon, 9 May 2022 08:46:35 +0000 (16:46 +0800)] 
[FLINK-27542] Refactor E2eTestBase with docker compose

This closes #114

8 days ago[FLINK-27517] Introduce rolling file writer to write one record each time for append...
openinx [Sun, 8 May 2022 12:02:20 +0000 (20:02 +0800)] 
[FLINK-27517] Introduce rolling file writer to write one record each time for append-only table

This closes #110

9 days ago[hotfix][docs] Correct the description of how to build this project
Yun Tang [Sat, 7 May 2022 09:54:30 +0000 (17:54 +0800)] 
[hotfix][docs] Correct the description of how to build this project

This closes #112

10 days ago[FLINK-27528] Introduce a new configuration option 'compact.rescale-bucket' for FileStore
Jane Chan [Fri, 6 May 2022 13:32:07 +0000 (21:32 +0800)] 
[FLINK-27528] Introduce a new configuration option 'compact.rescale-bucket' for FileStore

This closes #109

11 days ago[FLINK-27503] Rename sst file to data file
Jingsong Lee [Fri, 6 May 2022 03:43:06 +0000 (11:43 +0800)] 
[FLINK-27503] Rename sst file to data file

This closes #108

2 weeks ago[FLINK-27439] Add an e2e test for all supported value data types
tsreaper [Thu, 28 Apr 2022 12:32:31 +0000 (20:32 +0800)] 
[FLINK-27439] Add an e2e test for all supported value data types

This closes #106

2 weeks ago[FLINK-27439] Fix ClassNotFoundException when using array type in table store
tsreaper [Thu, 28 Apr 2022 10:48:20 +0000 (18:48 +0800)] 
[FLINK-27439] Fix ClassNotFoundException when using array type in table store

This closes #105

2 weeks ago[hotfix] Make CodeGenLoader public to avoid java doc generation error
JingsongLi [Wed, 27 Apr 2022 08:52:55 +0000 (16:52 +0800)] 
[hotfix] Make CodeGenLoader public to avoid java doc generation error

2 weeks ago[FLINK-27335] Optimize async compaction in MergeTreeWriter
Jingsong Lee [Wed, 27 Apr 2022 04:17:28 +0000 (12:17 +0800)] 
[FLINK-27335] Optimize async compaction in MergeTreeWriter

This closes #97

2 weeks ago[FLINK-27408] Package Flink runtime dependencies into associated table store modules...
tsreaper [Tue, 26 Apr 2022 05:41:17 +0000 (13:41 +0800)] 
[FLINK-27408] Package Flink runtime dependencies into associated table store modules instead of flink-table-store-dist

This closes #102

3 weeks ago[FLINK-27361] Introduce retry mechanism for SnapshotFinder
Jane Chan [Sun, 24 Apr 2022 08:33:29 +0000 (16:33 +0800)] 
[FLINK-27361] Introduce retry mechanism for SnapshotFinder

This closes #100

3 weeks ago[FLINK-26457] Introduce PartialUpdateMergeFunction
Jingsong Lee [Fri, 22 Apr 2022 01:55:15 +0000 (09:55 +0800)] 
[FLINK-26457] Introduce PartialUpdateMergeFunction

This closes #98

3 weeks ago[FLINK-27316] Prevent users from changing bucket number
Jane Chan [Thu, 21 Apr 2022 02:15:20 +0000 (10:15 +0800)] 
[FLINK-27316] Prevent users from changing bucket number

This closes #96

3 weeks ago[FLINK-27283] Add end to end tests for table store
tsreaper [Wed, 20 Apr 2022 06:19:10 +0000 (14:19 +0800)] 
[FLINK-27283] Add end to end tests for table store

This closes #93

3 weeks ago[hotfix] Add Documentation & Getting Started
Jingsong Lee [Tue, 19 Apr 2022 09:08:01 +0000 (17:08 +0800)] 
[hotfix] Add Documentation & Getting Started

This closes #94

4 weeks ago[FLINK-27286] Fix table store connector throws ClassNotFoundException: org.apache...
tsreaper [Mon, 18 Apr 2022 08:54:40 +0000 (16:54 +0800)] 
[FLINK-27286] Fix table store connector throws ClassNotFoundException: org.apache.flink.table.store.shaded.org.apache.flink.connector.file.table.RowDataPartitionComputer

This closes #92

4 weeks ago[FLINK-27264] Add IT case for concurrent batch overwrite and streaming insert
Jane Chan [Sat, 16 Apr 2022 06:54:06 +0000 (14:54 +0800)] 
[FLINK-27264] Add IT case for concurrent batch overwrite and streaming insert

This closes #91

4 weeks ago[hotfix] Adjust the default value of write-buffer-size to 128 MB
Jingsong Lee [Thu, 14 Apr 2022 10:13:53 +0000 (18:13 +0800)] 
[hotfix] Adjust the default value of write-buffer-size to 128 MB

This closes #90

4 weeks ago[FLINK-27123] Introduce filter predicate for 'LIKE' and fix filter pushdown bug
Jane Chan [Thu, 14 Apr 2022 06:31:17 +0000 (14:31 +0800)] 
[FLINK-27123] Introduce filter predicate for 'LIKE' and fix filter pushdown bug

This closes #87

4 weeks ago[FLINK-27172] Support bulk based format provided by Flink
Yubin Li [Tue, 12 Apr 2022 06:51:53 +0000 (14:51 +0800)] 
[FLINK-27172] Support bulk based format provided by Flink

This closes #89

5 weeks ago[hotfix] Add logs to file store compact for better tunning
tsreaper [Mon, 11 Apr 2022 07:35:18 +0000 (15:35 +0800)] 
[hotfix] Add logs to file store compact for better tunning

This closes #88

5 weeks ago[FLINK-27157] Add version field to manifest entries
Jingsong Lee [Mon, 11 Apr 2022 02:55:12 +0000 (10:55 +0800)] 
[FLINK-27157] Add version field to manifest entries

This closes #85

5 weeks ago[FLINK-27139] FileStoreCommitImpl#filterCommitted should exit when faced with expired...
tsreaper [Mon, 11 Apr 2022 02:44:10 +0000 (10:44 +0800)] 
[FLINK-27139] FileStoreCommitImpl#filterCommitted should exit when faced with expired files

This closes #84

5 weeks ago[FLINK-27158] Adjust default value of compaction and compress
Jingsong Lee [Mon, 11 Apr 2022 02:42:46 +0000 (10:42 +0800)] 
[FLINK-27158] Adjust default value of compaction and compress

This closes #86

5 weeks ago[FLINK-27136] Disable rolling file when writing level 0 sst files
tsreaper [Fri, 8 Apr 2022 11:19:01 +0000 (19:19 +0800)] 
[FLINK-27136] Disable rolling file when writing level 0 sst files

This closes #83

5 weeks ago[FLINK-27135] Rename 'file.path' table option in table store to 'path'
tsreaper [Fri, 8 Apr 2022 09:44:07 +0000 (17:44 +0800)] 
[FLINK-27135] Rename 'file.path' table option in table store to 'path'

This closes #82

5 weeks ago[hotfix] Shade kafka dependencies
tsreaper [Fri, 8 Apr 2022 09:03:11 +0000 (17:03 +0800)] 
[hotfix] Shade kafka dependencies

This closes #81

5 weeks ago[hotfix] Fix junit4 dependency version
tsreaper [Fri, 8 Apr 2022 07:30:29 +0000 (15:30 +0800)] 
[hotfix] Fix junit4 dependency version

This closes #78

5 weeks ago[hotfix] Value field should be named in value count mode
Jane Chan [Fri, 8 Apr 2022 07:25:05 +0000 (15:25 +0800)] 
[hotfix] Value field should be named in value count mode

This closes #79

5 weeks ago[hotfix] Add random group id to kafka consumer
Jingsong Lee [Fri, 8 Apr 2022 03:36:05 +0000 (11:36 +0800)] 
[hotfix] Add random group id to kafka consumer

This closes #77

5 weeks ago[FLINK-26913] Add IT case for computed column and watermark
Jane Chan [Fri, 8 Apr 2022 01:41:14 +0000 (09:41 +0800)] 
[FLINK-26913] Add IT case for computed column and watermark

This closes #76

5 weeks ago[FLINK-26856] Add ITCase for compound primary key and multi-partition
Jane Chan [Thu, 7 Apr 2022 01:20:25 +0000 (09:20 +0800)] 
[FLINK-26856] Add ITCase for compound primary key and multi-partition

This closes #73

5 weeks ago[FLINK-27085] Introduce snapshot.num-retained.min option
tsreaper [Wed, 6 Apr 2022 10:05:53 +0000 (18:05 +0800)] 
[FLINK-27085] Introduce snapshot.num-retained.min option

This closes #75

5 weeks ago[FLINK-27070] Reuse FileFormat instead of DecodingFormat/EncodingFormat to ensure...
tsreaper [Wed, 6 Apr 2022 08:06:30 +0000 (16:06 +0800)] 
[FLINK-27070] Reuse FileFormat instead of DecodingFormat/EncodingFormat to ensure thread safety

This closes #74

6 weeks ago[hotfix] Remove java reflect in TableConfigUtils
JingsongLi [Mon, 4 Apr 2022 07:21:52 +0000 (15:21 +0800)] 
[hotfix] Remove java reflect in TableConfigUtils

6 weeks ago[FLINK-26899] Introduce write/query table document for table store
Jingsong Lee [Mon, 4 Apr 2022 07:09:32 +0000 (15:09 +0800)] 
[FLINK-26899] Introduce write/query table document for table store

This closes #72

6 weeks ago[FLINK-27004] Use '<format>.<option>' instead of 'file.<format>.<option>' in table...
tsreaper [Sat, 2 Apr 2022 11:57:33 +0000 (19:57 +0800)] 
[FLINK-27004] Use '<format>.<option>' instead of 'file.<format>.<option>' in table properties of managed table

This closes #71

6 weeks ago[FLINK-26911] Introduce parallelism setter for table store
Jingsong Lee [Sat, 2 Apr 2022 06:27:09 +0000 (14:27 +0800)] 
[FLINK-26911] Introduce parallelism setter for table store

This closes #67

6 weeks ago[hotfix] Build java docs in docs.sh
JingsongLi [Fri, 1 Apr 2022 12:00:06 +0000 (20:00 +0800)] 
[hotfix] Build java docs in docs.sh

6 weeks ago[FLINK-26898] Introduce creating table document for table store
Jingsong Lee [Fri, 1 Apr 2022 11:39:45 +0000 (19:39 +0800)] 
[FLINK-26898] Introduce creating table document for table store

This closes #66

6 weeks ago[FLINK-26857] Add ITCase for projection and filter predicate
Jane Chan [Fri, 1 Apr 2022 10:34:20 +0000 (18:34 +0800)] 
[FLINK-26857] Add ITCase for projection and filter predicate

This closes #69

6 weeks ago[FLINK-26971] UniversalCompaction should pick by size ratio after picking by file num
Jingsong Lee [Fri, 1 Apr 2022 10:27:23 +0000 (18:27 +0800)] 
[FLINK-26971] UniversalCompaction should pick by size ratio after picking by file num

This closes #70

6 weeks ago[hotfix] Reset theme/book to Flink perfer version
JingsongLi [Fri, 1 Apr 2022 08:43:05 +0000 (16:43 +0800)] 
[hotfix] Reset theme/book to Flink perfer version

6 weeks ago[hotfix] Add thread name to StoreSinkWriter compaction thread pool
JingsongLi [Thu, 31 Mar 2022 02:07:52 +0000 (10:07 +0800)] 
[hotfix] Add thread name to StoreSinkWriter compaction thread pool

6 weeks ago[FLINK-26918] Add documentation build to Github Actions
Jingsong Lee [Wed, 30 Mar 2022 08:01:53 +0000 (16:01 +0800)] 
[FLINK-26918] Add documentation build to Github Actions

This closes #68

6 weeks ago[FLINK-26879] Fix that LogStartupMode.LATEST and LogStartupMode.FROM_TIMESTAMP don...
Jane Chan [Wed, 30 Mar 2022 06:43:42 +0000 (14:43 +0800)] 
[FLINK-26879] Fix that LogStartupMode.LATEST and LogStartupMode.FROM_TIMESTAMP don't work

This closes #65

7 weeks ago[FLINK-26877] Introduce auto type inference for filter push down
Jane Chan [Mon, 28 Mar 2022 06:49:12 +0000 (14:49 +0800)] 
[FLINK-26877] Introduce auto type inference for filter push down

This closes #64

7 weeks ago[hotfix] Change the version to 0.2-SNAPSHOT
JingsongLi [Mon, 28 Mar 2022 03:34:21 +0000 (11:34 +0800)] 
[hotfix] Change the version to 0.2-SNAPSHOT

7 weeks ago[hotfix] Add docs.sh to build document
JingsongLi [Mon, 28 Mar 2022 03:26:25 +0000 (11:26 +0800)] 
[hotfix] Add docs.sh to build document

7 weeks ago[FLINK-26867] Hybrid reading wrong because of disordered commits
Jingsong Lee [Fri, 25 Mar 2022 15:14:41 +0000 (23:14 +0800)] 
[FLINK-26867] Hybrid reading wrong because of disordered commits

This closes #63

7 weeks ago[FLINK-26863] Fix that filter predicate does not work
Jane Chan [Fri, 25 Mar 2022 15:13:07 +0000 (23:13 +0800)] 
[FLINK-26863] Fix that filter predicate does not work

This closes #62

7 weeks ago[FLINK-26778] Introduce snapshot latest and earliest hint files
Jingsong Lee [Fri, 25 Mar 2022 08:43:09 +0000 (16:43 +0800)] 
[FLINK-26778] Introduce snapshot latest and earliest hint files

This closes #56

7 weeks ago[FLINK-26860] FileStore continuous bug for delete row kind records
Jingsong Lee [Fri, 25 Mar 2022 08:00:26 +0000 (16:00 +0800)] 
[FLINK-26860] FileStore continuous bug for delete row kind records

This closes #61

7 weeks ago[FLINK-26669] Refactor ReadWriteTableITCase
Jane Chan [Fri, 25 Mar 2022 06:53:31 +0000 (14:53 +0800)] 
[FLINK-26669] Refactor ReadWriteTableITCase

This closes #58

7 weeks ago[FLINK-26744] Init document for table store and introduce quickstart
Jingsong Lee [Fri, 25 Mar 2022 02:45:26 +0000 (10:45 +0800)] 
[FLINK-26744] Init document for table store and introduce quickstart

This closes #53

7 weeks ago[FLINK-26834] Introduce BlockingIterator to help testing
Jingsong Lee [Thu, 24 Mar 2022 07:33:05 +0000 (15:33 +0800)] 
[FLINK-26834] Introduce BlockingIterator to help testing

This closes #60

7 weeks ago[hotfix] Revert "[FLINK-26677]": shade flink-connector-base instead of using connectors
JingsongLi [Thu, 24 Mar 2022 04:09:17 +0000 (12:09 +0800)] 
[hotfix] Revert "[FLINK-26677]": shade flink-connector-base instead of using connectors

7 weeks ago[hotfix] Fix unstable test FileStoreReadTest#testKeyProjection
tsreaper [Wed, 23 Mar 2022 13:00:34 +0000 (21:00 +0800)] 
[hotfix] Fix unstable test FileStoreReadTest#testKeyProjection

This closes #59

7 weeks ago[FLINK-26791] Finish projection push down for table store
Jingsong Lee [Wed, 23 Mar 2022 12:34:26 +0000 (20:34 +0800)] 
[FLINK-26791] Finish projection push down for table store

This closes #57

7 weeks ago[FLINK-26703] Introduce flink-table-store-dist module for packaging
tsreaper [Wed, 23 Mar 2022 06:23:11 +0000 (14:23 +0800)] 
[FLINK-26703] Introduce flink-table-store-dist module for packaging

This closes #50

7 weeks ago[FLINK-26753] PK constraint should include partition keys if table is partitioned
Jane Chan [Wed, 23 Mar 2022 03:10:14 +0000 (11:10 +0800)] 
[FLINK-26753] PK constraint should include partition keys if table is partitioned

This closes #54

8 weeks ago[hotfix] Optimize getChangelogMode in TableStoreSink and TableStoreSource
Jingsong Lee [Mon, 21 Mar 2022 09:47:41 +0000 (17:47 +0800)] 
[hotfix] Optimize getChangelogMode in TableStoreSink and TableStoreSource

This closes #55

8 weeks ago[FLINK-26711] Remove change tracking in TableStore
Jingsong Lee [Fri, 18 Mar 2022 06:31:19 +0000 (14:31 +0800)] 
[FLINK-26711] Remove change tracking in TableStore

This closes #52

8 weeks ago[hotfix] Rename ambiguous key to primary key
Jane Chan [Fri, 18 Mar 2022 02:39:37 +0000 (10:39 +0800)] 
[hotfix] Rename ambiguous key to primary key

This closes #51

8 weeks ago[FLINK-26679] Add FileStore Continuous Reading ITCase
Jingsong Lee [Thu, 17 Mar 2022 10:44:54 +0000 (18:44 +0800)] 
[FLINK-26679] Add FileStore Continuous Reading ITCase

This closes #48

8 weeks ago[FLINK-26648] Delegate table planner dependencies with separate modules
tsreaper [Thu, 17 Mar 2022 09:33:51 +0000 (17:33 +0800)] 
[FLINK-26648] Delegate table planner dependencies with separate modules

This closes #46

2 months ago[hotfix] Disable unstable LogStoreSinkITCase
JingsongLi [Thu, 17 Mar 2022 08:55:05 +0000 (16:55 +0800)] 
[hotfix] Disable unstable LogStoreSinkITCase

2 months ago[hotfix] Fix the config casting in TableStoreFactory.enrichOptions
Jingsong Lee [Thu, 17 Mar 2022 03:35:57 +0000 (11:35 +0800)] 
[hotfix] Fix the config casting in TableStoreFactory.enrichOptions

This closes #49

2 months ago[FLINK-26677] Make flink-connector-base dependency consistent
Yubin Li [Wed, 16 Mar 2022 10:37:06 +0000 (18:37 +0800)] 
[FLINK-26677] Make flink-connector-base dependency consistent

This closes #47

2 months ago[FLINK-26475] FileStoreScan supports incremental consuming
Jingsong Lee [Tue, 15 Mar 2022 14:14:34 +0000 (22:14 +0800)] 
[FLINK-26475] FileStoreScan supports incremental consuming

This closes #43

2 months ago[FLINK-26535] Introduce StoreTableSource And StoreTableSink
Jane Chan [Tue, 15 Mar 2022 13:16:14 +0000 (21:16 +0800)] 
[FLINK-26535] Introduce StoreTableSource And StoreTableSink

This closes #41

2 months ago[hotfix] Remove 'table.path' option and let FileStore construct table path dynamically
Jane Chan [Tue, 15 Mar 2022 09:01:05 +0000 (17:01 +0800)] 
[hotfix] Remove 'table.path' option and let FileStore construct table path dynamically

This closes #45

2 months ago[hotfix][docs] Remove unnecessary html link tags and fix typo
Leonard Xu [Tue, 15 Mar 2022 08:46:08 +0000 (16:46 +0800)] 
[hotfix][docs] Remove unnecessary html link tags and fix typo

This closes #44.

2 months ago[FLINK-26458] Rename Accumulator to MergeFunction
Jane Chan [Mon, 14 Mar 2022 14:14:27 +0000 (22:14 +0800)] 
[FLINK-26458] Rename Accumulator to MergeFunction

This closes #42

2 months ago[FLINK-26544] Apply key & value filter in FileStoreScanImpl
tsreaper [Fri, 11 Mar 2022 04:01:58 +0000 (12:01 +0800)] 
[FLINK-26544] Apply key & value filter in FileStoreScanImpl

This closes #38

2 months ago[FLINK-26530] Introduce TableStore API and refactor ITCases
Jingsong Lee [Fri, 11 Mar 2022 03:56:41 +0000 (11:56 +0800)] 
[FLINK-26530] Introduce TableStore API and refactor ITCases

This closes #36

2 months ago[FLINK-26293] Improve FileStoreCommitTest.testSnapshotAddLogOffset
JingsongLi [Thu, 10 Mar 2022 09:47:08 +0000 (17:47 +0800)] 
[FLINK-26293] Improve FileStoreCommitTest.testSnapshotAddLogOffset

2 months ago[FLINK-26293] Store log offsets in snapshot
SteNicholas [Thu, 10 Mar 2022 09:27:48 +0000 (17:27 +0800)] 
[FLINK-26293] Store log offsets in snapshot

This closes #31

2 months ago[FLINK-26567] FileStoreSourceSplitReader should deal with value count
Jingsong Lee [Thu, 10 Mar 2022 08:55:48 +0000 (16:55 +0800)] 
[FLINK-26567] FileStoreSourceSplitReader should deal with value count

This closes #40

2 months ago[FLINK-26562] Introduce table.path option for FileStoreOptions
Jane Chan [Thu, 10 Mar 2022 04:58:41 +0000 (12:58 +0800)] 
[FLINK-26562] Introduce table.path option for FileStoreOptions

This closes #39

2 months ago[FLINK-26441] Add a new OVERWRITE snapshot commit kind
tsreaper [Wed, 9 Mar 2022 07:50:16 +0000 (15:50 +0800)] 
[FLINK-26441] Add a new OVERWRITE snapshot commit kind

This closes #37

2 months ago[FLINK-26346] Add statistics collecting to sst files
tsreaper [Wed, 9 Mar 2022 03:05:42 +0000 (11:05 +0800)] 
[FLINK-26346] Add statistics collecting to sst files

This closes #33

2 months ago[hotfix] Refactor and reuse codes in TableStoreFactory
JingsongLi [Wed, 9 Mar 2022 02:37:52 +0000 (10:37 +0800)] 
[hotfix] Refactor and reuse codes in TableStoreFactory

2 months ago[FLINK-26423] Integrate log store to StoreSink
Jingsong Lee [Tue, 8 Mar 2022 06:47:41 +0000 (14:47 +0800)] 
[FLINK-26423] Integrate log store to StoreSink

This closes #28

2 months ago[hotfix] Update comments in FileStoreExpireImpl
JingsongLi [Mon, 7 Mar 2022 02:56:12 +0000 (10:56 +0800)] 
[hotfix] Update comments in FileStoreExpireImpl

2 months ago[hotfix] Let FileStore assign key/value/partition type directly to StoreSink to avoid...
Jane Chan [Thu, 3 Mar 2022 14:02:13 +0000 (22:02 +0800)] 
[hotfix] Let FileStore assign key/value/partition type directly to StoreSink to avoid serialization error caused by incorrect projection

This closes #35

2 months ago[hotfix] Rename ambiguous row type to value type
Jingsong Lee [Thu, 3 Mar 2022 09:07:32 +0000 (17:07 +0800)] 
[hotfix] Rename ambiguous row type to value type

This closes #34

2 months ago[hotfix] Fix ClassCastException when StoreSinkWriter#writeToFileStore encountered...
Jane Chan [Thu, 3 Mar 2022 07:31:50 +0000 (15:31 +0800)] 
[hotfix] Fix ClassCastException when StoreSinkWriter#writeToFileStore encountered non-pk record

This closes #32

2 months ago[FLINK-26247] Optimize expire by only reading new changes in a snapshot
tsreaper [Thu, 3 Mar 2022 06:18:06 +0000 (14:18 +0800)] 
[FLINK-26247] Optimize expire by only reading new changes in a snapshot

This closes #30

2 months ago[FLINK-26442] Allow ManifestFile to write a list of ManifestFileMeta into multiple...
tsreaper [Wed, 2 Mar 2022 06:45:10 +0000 (14:45 +0800)] 
[FLINK-26442] Allow ManifestFile to write a list of ManifestFileMeta into multiple files if too many

This closes #29

2 months ago[FLINK-26031] Support projection pushdown on keys and values
tsreaper [Tue, 1 Mar 2022 11:28:43 +0000 (19:28 +0800)] 
[FLINK-26031] Support projection pushdown on keys and values

This closes #18

2 months ago[hotfix] Refactor OperationTestUtils into TestFileStore and remove unnecessary repeat...
tsreaper [Tue, 1 Mar 2022 09:49:27 +0000 (17:49 +0800)] 
[hotfix] Refactor OperationTestUtils into TestFileStore and remove unnecessary repeated tests

This closes #27