[HUDI-2044] Integrate consumers with rocksDB and compression within External Spillabl...
authorrmahindra123 <76502047+rmahindra123@users.noreply.github.com>
Wed, 28 Jul 2021 05:31:03 +0000 (22:31 -0700)
committerGitHub <noreply@github.com>
Wed, 28 Jul 2021 05:31:03 +0000 (01:31 -0400)
commit8fef50e237b2342ea3366be32950a2b87a9608c4
tree93da7f30876fe242b380f3a836dd108530610774
parent00cd35f90ad0cd96a943edd148bf881fc4b7bb5b
[HUDI-2044] Integrate consumers with rocksDB and compression within External Spillable Map (#3318)
27 files changed:
hudi-cli/src/main/java/org/apache/hudi/cli/commands/HoodieLogFileCommand.java
hudi-cli/src/test/java/org/apache/hudi/cli/commands/TestHoodieLogFileCommand.java
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/embedded/EmbeddedTimelineServerHelper.java
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/embedded/EmbeddedTimelineService.java
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieWriteConfig.java
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieMergeHandle.java
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/HoodieTable.java
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/action/compact/HoodieFlinkMergeOnReadTableCompactor.java
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/cluster/SparkExecuteClusteringCommitActionExecutor.java
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/compact/HoodieSparkMergeOnReadTableCompactor.java
hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/io/TestHoodieMergeHandle.java
hudi-common/src/main/java/org/apache/hudi/common/config/HoodieCommonConfig.java [new file with mode: 0644]
hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieMergedLogRecordScanner.java
hudi-common/src/main/java/org/apache/hudi/common/table/view/FileSystemViewManager.java
hudi-common/src/main/java/org/apache/hudi/common/table/view/SpillableMapBasedFileSystemView.java
hudi-common/src/main/java/org/apache/hudi/metadata/HoodieBackedTableMetadata.java
hudi-common/src/main/java/org/apache/hudi/metadata/HoodieMetadataMergedLogRecordScanner.java
hudi-common/src/test/java/org/apache/hudi/common/functional/TestHoodieLogFormat.java
hudi-common/src/test/java/org/apache/hudi/common/table/view/TestSpillableMapBasedFileSystemView.java
hudi-common/src/test/java/org/apache/hudi/common/table/view/TestSpillableMapBasedIncrementalFSViewSync.java
hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/BootstrapFunction.java
hudi-flink/src/test/java/org/apache/hudi/utils/TestData.java
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/RealtimeCompactedRecordReader.java
hudi-hadoop-mr/src/test/java/org/apache/hudi/hadoop/realtime/TestHoodieRealtimeRecordReader.java
hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/reader/DFSHoodieDatasetInputReader.java
hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/TimelineService.java
hudi-timeline-service/src/test/java/org/apache/hudi/timeline/service/functional/TestRemoteHoodieTableFileSystemView.java