This is an automated email from the ASF dual-hosted git repository.
codope pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from af3b2937a38 [HUDI-6655] Fix
TestWriteMergeOnRead#testConsistentBucketIndex (#9380)
add e1c9102d6c7 [HUDI-6647] Expand Hudi Java Client Functionality (#9371)
No new revisions were added by this update.
Summary of changes:
.../testutils/HoodieCLIIntegrationTestHarness.java | 4 +-
hudi-client/hudi-client-common/pom.xml | 31 +
.../hudi/client/BaseHoodieTableServiceClient.java | 232 ++-
.../apache/hudi/client/BaseHoodieWriteClient.java | 66 +-
.../GenericRecordValidationTestUtils.java | 0
.../hudi/testutils/HoodieMergeOnReadTestUtils.java | 6 +-
.../hudi/utils/HoodieWriterClientTestHarness.java | 232 +++
.../hudi/client/HoodieFlinkTableServiceClient.java | 113 +-
.../apache/hudi/client/HoodieFlinkWriteClient.java | 46 -
.../hudi/client/HoodieJavaTableServiceClient.java | 42 +-
.../apache/hudi/client/HoodieJavaWriteClient.java | 39 +-
.../apache/hudi/index/JavaHoodieIndexFactory.java | 22 +
.../hudi/table/HoodieJavaCopyOnWriteTable.java | 15 +-
.../hudi/table/HoodieJavaMergeOnReadTable.java | 20 +
.../commit/BaseJavaCommitActionExecutor.java | 15 +-
.../table/action/commit/JavaUpsertPartitioner.java | 5 +
.../BaseJavaDeltaCommitActionExecutor.java | 38 +
.../JavaUpsertDeltaCommitActionExecutor.java | 53 +
.../TestHoodieJavaClientOnCopyOnWriteStorage.java | 1629 ++++++++++++++++++++
.../TestHoodieJavaClientOnMergeOnReadStorage.java | 172 +++
.../testutils/HoodieJavaClientTestHarness.java | 676 +++++++-
.../hudi/client/SparkRDDTableServiceClient.java | 275 +---
.../apache/hudi/client/SparkRDDWriteClient.java | 80 +-
.../java/org/apache/hudi/client/TestMultiFS.java | 4 +-
.../hudi/client/TestUpdateSchemaEvolution.java | 4 +-
...parkConsistentBucketClusteringPlanStrategy.java | 4 +-
.../functional/TestConsistentBucketIndex.java | 9 +-
.../TestHoodieClientOnCopyOnWriteStorage.java | 1 -
.../hudi/client/functional/TestHoodieIndex.java | 2 +-
.../client/functional/TestHoodieMetadataBase.java | 4 +-
.../TestRemoteFileSystemViewWithMetadataTable.java | 4 +-
.../TestSparkConsistentBucketClustering.java | 7 +-
.../TestBoundedInMemoryExecutorInSpark.java | 4 +-
.../hudi/execution/TestBoundedInMemoryQueue.java | 4 +-
.../execution/TestDisruptorExecutionInSpark.java | 4 +-
.../hudi/execution/TestDisruptorMessageQueue.java | 4 +-
.../hudi/execution/TestSimpleExecutionInSpark.java | 4 +-
.../TestBulkInsertInternalPartitionerForRows.java | 4 +-
.../TestRDDSimpleBucketBulkInsertPartitioner.java | 4 +-
.../index/bucket/TestHoodieSimpleBucketIndex.java | 4 +-
.../hudi/io/TestHoodieKeyLocationFetchHandle.java | 7 +-
.../org/apache/hudi/io/TestHoodieMergeHandle.java | 6 +-
.../apache/hudi/io/TestHoodieTimelineArchiver.java | 4 +-
.../row/TestHoodieInternalRowParquetWriter.java | 4 +-
.../io/storage/row/TestHoodieRowCreateHandle.java | 4 +-
.../apache/hudi/table/TestConsistencyGuard.java | 4 +-
.../hudi/table/TestHoodieMergeOnReadTable.java | 2 +-
.../clean/TestCleanerInsertAndCleanByVersions.java | 4 +-
.../table/action/cluster/ClusteringTestUtils.java | 4 +-
.../table/action/compact/TestHoodieCompactor.java | 8 +-
.../TestHoodieSparkMergeOnReadTableCompaction.java | 2 +-
...dieSparkMergeOnReadTableInsertUpdateDelete.java | 2 +-
.../hudi/testutils/HoodieClientTestBase.java | 161 +-
.../hudi/testutils/HoodieClientTestUtils.java | 15 -
...ness.java => HoodieSparkClientTestHarness.java} | 29 +-
.../HoodieBulkInsertInternalWriterTestBase.java | 7 +-
.../org/apache/hudi/TestSparkFilterHelper.scala | 4 +-
.../sources/helpers/TestCloudObjectsSelector.java | 4 +-
.../helpers/TestCloudObjectsSelectorCommon.java | 4 +-
.../helpers/TestDFSPathSelectorCommonMethods.java | 4 +-
.../helpers/TestDatePartitionPathSelector.java | 4 +-
.../sources/helpers/TestS3EventsMetaSelector.java | 4 +-
62 files changed, 3329 insertions(+), 840 deletions(-)
rename hudi-client/{hudi-spark-client =>
hudi-client-common}/src/test/java/org/apache/hudi/testutils/GenericRecordValidationTestUtils.java
(100%)
rename hudi-client/{hudi-spark-client =>
hudi-client-common}/src/test/java/org/apache/hudi/testutils/HoodieMergeOnReadTestUtils.java
(98%)
create mode 100644
hudi-client/hudi-client-common/src/test/java/org/apache/hudi/utils/HoodieWriterClientTestHarness.java
create mode 100644
hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/deltacommit/JavaUpsertDeltaCommitActionExecutor.java
create mode 100644
hudi-client/hudi-java-client/src/test/java/org/apache/hudi/client/functional/TestHoodieJavaClientOnCopyOnWriteStorage.java
create mode 100644
hudi-client/hudi-java-client/src/test/java/org/apache/hudi/client/functional/TestHoodieJavaClientOnMergeOnReadStorage.java
rename
hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/testutils/{HoodieClientTestHarness.java
=> HoodieSparkClientTestHarness.java} (95%)
