Zoltan Chovan has uploaded this change for review. ( http://gerrit.cloudera.org:8080/23003
Change subject: KUDU-3662 [3/n] Setup source and sink and tests ...................................................................... KUDU-3662 [3/n] Setup source and sink and tests - Introduce CustomReplicationRowResultConverter to detect delete rows on the source side - Add CustomReplicationOperationMapper to map Flink Row to Kudu upsert/delete operations - Wire source and sink using the above in ReplicationEnvProvider - Set up ReplicationTestBase with separate source and sink Kudu test harnesses to test replication logic - Add basic replication tests verifying row count and content equality Change-Id: I3dd7122933b125b6d4c6dd5dde27a7e8c3f790d4 --- M java/config/spotbugs/excludeFilter.xml M java/gradle/dependencies.gradle M java/kudu-replication/build.gradle A java/kudu-replication/src/main/java/org/apache/kudu/replication/CustomReplicationOperationMapper.java A java/kudu-replication/src/main/java/org/apache/kudu/replication/CustomReplicationRowRestultConverter.java M java/kudu-replication/src/main/java/org/apache/kudu/replication/ReplicationEnvProvider.java A java/kudu-replication/src/test/java/org/apache/kudu/replication/ReplicationTestBase.java A java/kudu-replication/src/test/java/org/apache/kudu/replication/TestReplication.java A java/kudu-replication/src/test/resources/log4j2.properties M java/kudu-test-utils/src/main/java/org/apache/kudu/test/ClientTestUtil.java 10 files changed, 490 insertions(+), 52 deletions(-) git pull ssh://gerrit.cloudera.org:29418/kudu refs/changes/03/23003/1 -- To view, visit http://gerrit.cloudera.org:8080/23003 To unsubscribe, visit http://gerrit.cloudera.org:8080/settings Gerrit-Project: kudu Gerrit-Branch: master Gerrit-MessageType: newchange Gerrit-Change-Id: I3dd7122933b125b6d4c6dd5dde27a7e8c3f790d4 Gerrit-Change-Number: 23003 Gerrit-PatchSet: 1 Gerrit-Owner: Zoltan Chovan <[email protected]>
