WIP: test branch to merge back Table API to apache/flink - #231

Open

imaffe wants to merge 20 commits into

affe/169-apachecut

Commits on Oct 11, 2022

a. Pulsar Table Source implementation code
imaffe
committed
1de7805
b. Pulsar Table Sink implementation code
imaffe
committed
7fe3a0a
c. Pulsar Table Factory, config utils and validation logics
imaffe
committed
49b4fe5
d. test utils classes: mocks, POJO and static util classes
imaffe
committed
c5f1e61
e. PulsarTableTestBase and IT Case
imaffe
committed
1cbb488
f. PulsarTableFactoryTest
imaffe
committed
4e8f43f
g. option util and validation logic tests
imaffe
committed
e9749fb
h. pom and manifest file changes
imaffe
committed
688588f
i. doc configuration changes
imaffe
committed
0db13ea
j. DataStream: stopCursor add equals()
imaffe
committed
bf20d2a
k. DataStream: add keyBytes() method for writer
imaffe
committed
7ce3909
l. DataStream: add typeInformation for Schema Factory
imaffe
committed
d69b29c
m. DataStream: startCursor add equals()
imaffe
committed
7f19734
n. apply checkstyle and spotless
imaffe
committed
8d4b272
o. DataStream: make one operator method createProducer() public
imaffe
committed
6ef2f61
p. set test default paralellism to 2
imaffe
committed
8e6e3a3
1. fix unapproved license issue
imaffe
committed
23efa42

Commits on Oct 14, 2022

2. refactor ITCase to use MiniCluster
imaffe
committed
21977c7

Commits on Oct 17, 2022

3: Stop using MiniClusterExtension as it will cause resource failure
imaffe
committed
7bb30d9

Commits on Oct 18, 2022

4. remove unnecessary public declarations in test
imaffe
committed
614d925