You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by vi...@apache.org on 2020/08/06 04:35:09 UTC
[hudi] branch master updated (c21209c -> 51ea27d)
This is an automated email from the ASF dual-hosted git repository.
vinoth pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git.
from c21209c [HUDI-1149] Added a console metrics reporter and associated unit tests.
add 51ea27d [HUDI-875] Abstract hudi-sync-common, and support hudi-hive-sync, hudi-dla-sync (#1810)
No new revisions were added by this update.
Summary of changes:
docker/demo/setup_demo_container.sh | 2 +-
hudi-spark/pom.xml | 5 +
.../scala/org/apache/hudi/DataSourceOptions.scala | 5 +
.../org/apache/hudi/HoodieSparkSqlWriter.scala | 55 ++-
.../hudi-dla-sync}/pom.xml | 224 +++++-------
.../hudi-dla-sync}/src/assembly/src.xml | 0
.../java/org/apache/hudi/dla/DLASyncConfig.java | 63 ++--
.../main/java/org/apache/hudi/dla/DLASyncTool.java | 163 ++++-----
.../java/org/apache/hudi/dla/HoodieDLAClient.java | 403 +++++++++++++++++++++
.../main/java/org/apache/hudi/dla/util/Utils.java | 75 ++++
.../org/apache/hudi/dla/TestDLASyncConfig.java | 54 +++
.../test/resources/log4j-surefire-quiet.properties | 0
.../src/test/resources/log4j-surefire.properties | 0
.../hudi-hive-sync}/pom.xml | 7 +
.../hudi-hive-sync}/run_sync_tool.sh | 0
.../hudi-hive-sync}/src/assembly/src.xml | 0
.../java/org/apache/hudi/hive/HiveSyncConfig.java | 0
.../java/org/apache/hudi/hive/HiveSyncTool.java | 9 +-
.../org/apache/hudi/hive/HoodieHiveClient.java | 125 +------
.../apache/hudi/hive/HoodieHiveSyncException.java | 0
.../hudi/hive/MultiPartKeysValueExtractor.java | 0
.../apache/hudi/hive/NonPartitionedExtractor.java | 0
.../apache/hudi/hive/PartitionValueExtractor.java | 0
.../org/apache/hudi/hive/SchemaDifference.java | 4 +-
.../SlashEncodedDayPartitionValueExtractor.java | 0
.../apache/hudi/hive/util/ColumnNameXLator.java | 0
.../org/apache/hudi/hive/util/HiveSchemaUtil.java | 0
.../org/apache/hudi/hive/TestHiveSyncTool.java | 4 +-
.../hudi/hive/testutils/HiveTestService.java | 0
.../apache/hudi/hive/testutils/HiveTestUtil.java | 0
.../test/resources/log4j-surefire-quiet.properties | 0
.../src/test/resources/log4j-surefire.properties | 0
.../hadoop => hudi-sync/hudi-sync-common}/pom.xml | 74 ++--
.../hudi/sync/common/AbstractSyncHoodieClient.java | 189 ++++++++++
.../apache/hudi/sync/common/AbstractSyncTool.java | 25 +-
.../hudi/sync/common/HoodieSyncException.java | 12 +-
hudi-sync/pom.xml | 38 ++
.../hudi/utilities/deltastreamer/DeltaSync.java | 58 ++-
.../deltastreamer/HoodieDeltaStreamer.java | 13 +
.../deltastreamer/HoodieDeltaStreamerMetrics.java | 23 +-
packaging/hudi-hive-sync-bundle/pom.xml | 3 +-
packaging/hudi-spark-bundle/pom.xml | 1 +
packaging/hudi-utilities-bundle/pom.xml | 1 +
pom.xml | 2 +-
44 files changed, 1174 insertions(+), 463 deletions(-)
copy {hudi-timeline-service => hudi-sync/hudi-dla-sync}/pom.xml (54%)
copy {hudi-hive-sync => hudi-sync/hudi-dla-sync}/src/assembly/src.xml (100%)
copy hudi-hive-sync/src/main/java/org/apache/hudi/hive/HiveSyncConfig.java => hudi-sync/hudi-dla-sync/src/main/java/org/apache/hudi/dla/DLASyncConfig.java (61%)
copy hudi-hive-sync/src/main/java/org/apache/hudi/hive/HiveSyncTool.java => hudi-sync/hudi-dla-sync/src/main/java/org/apache/hudi/dla/DLASyncTool.java (50%)
create mode 100644 hudi-sync/hudi-dla-sync/src/main/java/org/apache/hudi/dla/HoodieDLAClient.java
create mode 100644 hudi-sync/hudi-dla-sync/src/main/java/org/apache/hudi/dla/util/Utils.java
create mode 100644 hudi-sync/hudi-dla-sync/src/test/java/org/apache/hudi/dla/TestDLASyncConfig.java
rename {hudi-hive-sync => hudi-sync/hudi-dla-sync}/src/test/resources/log4j-surefire-quiet.properties (100%)
rename {hudi-hive-sync => hudi-sync/hudi-dla-sync}/src/test/resources/log4j-surefire.properties (100%)
rename {hudi-hive-sync => hudi-sync/hudi-hive-sync}/pom.xml (96%)
rename {hudi-hive-sync => hudi-sync/hudi-hive-sync}/run_sync_tool.sh (100%)
rename {hudi-hive-sync => hudi-sync/hudi-hive-sync}/src/assembly/src.xml (100%)
rename {hudi-hive-sync => hudi-sync/hudi-hive-sync}/src/main/java/org/apache/hudi/hive/HiveSyncConfig.java (100%)
rename {hudi-hive-sync => hudi-sync/hudi-hive-sync}/src/main/java/org/apache/hudi/hive/HiveSyncTool.java (96%)
rename {hudi-hive-sync => hudi-sync/hudi-hive-sync}/src/main/java/org/apache/hudi/hive/HoodieHiveClient.java (82%)
copy {hudi-hive-sync => hudi-sync/hudi-hive-sync}/src/main/java/org/apache/hudi/hive/HoodieHiveSyncException.java (100%)
rename {hudi-hive-sync => hudi-sync/hudi-hive-sync}/src/main/java/org/apache/hudi/hive/MultiPartKeysValueExtractor.java (100%)
rename {hudi-hive-sync => hudi-sync/hudi-hive-sync}/src/main/java/org/apache/hudi/hive/NonPartitionedExtractor.java (100%)
rename {hudi-hive-sync => hudi-sync/hudi-hive-sync}/src/main/java/org/apache/hudi/hive/PartitionValueExtractor.java (100%)
rename {hudi-hive-sync => hudi-sync/hudi-hive-sync}/src/main/java/org/apache/hudi/hive/SchemaDifference.java (98%)
rename {hudi-hive-sync => hudi-sync/hudi-hive-sync}/src/main/java/org/apache/hudi/hive/SlashEncodedDayPartitionValueExtractor.java (100%)
rename {hudi-hive-sync => hudi-sync/hudi-hive-sync}/src/main/java/org/apache/hudi/hive/util/ColumnNameXLator.java (100%)
rename {hudi-hive-sync => hudi-sync/hudi-hive-sync}/src/main/java/org/apache/hudi/hive/util/HiveSchemaUtil.java (100%)
rename {hudi-hive-sync => hudi-sync/hudi-hive-sync}/src/test/java/org/apache/hudi/hive/TestHiveSyncTool.java (99%)
rename {hudi-hive-sync => hudi-sync/hudi-hive-sync}/src/test/java/org/apache/hudi/hive/testutils/HiveTestService.java (100%)
rename {hudi-hive-sync => hudi-sync/hudi-hive-sync}/src/test/java/org/apache/hudi/hive/testutils/HiveTestUtil.java (100%)
copy {hudi-timeline-service => hudi-sync/hudi-hive-sync}/src/test/resources/log4j-surefire-quiet.properties (100%)
copy {hudi-timeline-service => hudi-sync/hudi-hive-sync}/src/test/resources/log4j-surefire.properties (100%)
copy {docker/hoodie/hadoop => hudi-sync/hudi-sync-common}/pom.xml (52%)
create mode 100644 hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/AbstractSyncHoodieClient.java
copy hudi-spark/src/main/scala/org/apache/hudi/package.scala => hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/AbstractSyncTool.java (60%)
rename hudi-hive-sync/src/main/java/org/apache/hudi/hive/HoodieHiveSyncException.java => hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/HoodieSyncException.java (77%)
create mode 100644 hudi-sync/pom.xml