This is an automated email from the ASF dual-hosted git repository.
danny0405 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new 967408cc9b76 refactor: move source assign package under split (#18253)
967408cc9b76 is described below
commit 967408cc9b765027ab1da3a91f684f09e91a66b9
Author: Peter Huang <[email protected]>
AuthorDate: Thu Feb 26 04:34:40 2026 -0800
refactor: move source assign package under split (#18253)
---
.../src/main/java/org/apache/hudi/source/HoodieSource.java | 4 ++--
.../apache/hudi/source/split/DefaultHoodieSplitProvider.java | 2 +-
.../{ => split}/assign/DefaultHoodieSplitAssigner.java | 2 +-
.../hudi/source/{ => split}/assign/HoodieSplitAssigner.java | 2 +-
.../hudi/source/{ => split}/assign/HoodieSplitAssigners.java | 2 +-
.../source/{ => split}/assign/HoodieSplitBucketAssigner.java | 2 +-
.../source/{ => split}/assign/HoodieSplitNumberAssigner.java | 2 +-
.../enumerator/TestHoodieContinuousSplitEnumerator.java | 2 +-
.../source/enumerator/TestHoodieStaticSplitEnumerator.java | 2 +-
.../hudi/source/split/TestDefaultHoodieSplitProvider.java | 12 +++++++-----
.../{ => split}/assign/TestDefaultHoodieSplitAssigner.java | 2 +-
.../source/{ => split}/assign/TestHoodieSplitAssigners.java | 2 +-
.../{ => split}/assign/TestHoodieSplitBucketAssigner.java | 2 +-
.../{ => split}/assign/TestHoodieSplitNumberAssigner.java | 2 +-
14 files changed, 21 insertions(+), 19 deletions(-)
diff --git
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/HoodieSource.java
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/HoodieSource.java
index d3499b64b477..fcfa4770efb5 100644
---
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/HoodieSource.java
+++
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/HoodieSource.java
@@ -25,8 +25,8 @@ import org.apache.hudi.common.model.HoodieTableType;
import org.apache.hudi.common.table.HoodieTableMetaClient;
import org.apache.hudi.common.util.Option;
import org.apache.hudi.common.util.ValidationUtils;
-import org.apache.hudi.source.assign.HoodieSplitAssigner;
-import org.apache.hudi.source.assign.HoodieSplitAssigners;
+import org.apache.hudi.source.split.assign.HoodieSplitAssigner;
+import org.apache.hudi.source.split.assign.HoodieSplitAssigners;
import org.apache.hudi.configuration.FlinkOptions;
import org.apache.hudi.exception.HoodieException;
import org.apache.hudi.source.enumerator.HoodieContinuousSplitEnumerator;
diff --git
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/split/DefaultHoodieSplitProvider.java
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/split/DefaultHoodieSplitProvider.java
index af3a38f78b8e..13a14dffcda8 100644
---
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/split/DefaultHoodieSplitProvider.java
+++
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/split/DefaultHoodieSplitProvider.java
@@ -19,7 +19,7 @@
package org.apache.hudi.source.split;
import org.apache.hudi.common.util.Option;
-import org.apache.hudi.source.assign.HoodieSplitAssigner;
+import org.apache.hudi.source.split.assign.HoodieSplitAssigner;
import javax.annotation.Nullable;
diff --git
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/assign/DefaultHoodieSplitAssigner.java
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/split/assign/DefaultHoodieSplitAssigner.java
similarity index 97%
rename from
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/assign/DefaultHoodieSplitAssigner.java
rename to
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/split/assign/DefaultHoodieSplitAssigner.java
index 6bd09631f2dc..98626584e06f 100644
---
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/assign/DefaultHoodieSplitAssigner.java
+++
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/split/assign/DefaultHoodieSplitAssigner.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.hudi.source.assign;
+package org.apache.hudi.source.split.assign;
import org.apache.flink.runtime.state.KeyGroupRangeAssignment;
import org.apache.hudi.source.split.HoodieSourceSplit;
diff --git
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/assign/HoodieSplitAssigner.java
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/split/assign/HoodieSplitAssigner.java
similarity index 96%
rename from
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/assign/HoodieSplitAssigner.java
rename to
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/split/assign/HoodieSplitAssigner.java
index 2224da5443c3..cae886394864 100644
---
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/assign/HoodieSplitAssigner.java
+++
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/split/assign/HoodieSplitAssigner.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.hudi.source.assign;
+package org.apache.hudi.source.split.assign;
import org.apache.hudi.source.split.HoodieSourceSplit;
diff --git
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/assign/HoodieSplitAssigners.java
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/split/assign/HoodieSplitAssigners.java
similarity index 96%
rename from
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/assign/HoodieSplitAssigners.java
rename to
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/split/assign/HoodieSplitAssigners.java
index 639b316381b3..e50751f79ab4 100644
---
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/assign/HoodieSplitAssigners.java
+++
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/split/assign/HoodieSplitAssigners.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.hudi.source.assign;
+package org.apache.hudi.source.split.assign;
import org.apache.flink.configuration.Configuration;
import org.apache.hudi.configuration.OptionsResolver;
diff --git
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/assign/HoodieSplitBucketAssigner.java
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/split/assign/HoodieSplitBucketAssigner.java
similarity index 97%
rename from
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/assign/HoodieSplitBucketAssigner.java
rename to
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/split/assign/HoodieSplitBucketAssigner.java
index b8d919ff74ad..c13d28b03e75 100644
---
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/assign/HoodieSplitBucketAssigner.java
+++
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/split/assign/HoodieSplitBucketAssigner.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.hudi.source.assign;
+package org.apache.hudi.source.split.assign;
import org.apache.hudi.index.bucket.BucketIdentifier;
import org.apache.hudi.source.split.HoodieSourceSplit;
diff --git
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/assign/HoodieSplitNumberAssigner.java
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/split/assign/HoodieSplitNumberAssigner.java
similarity index 97%
rename from
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/assign/HoodieSplitNumberAssigner.java
rename to
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/split/assign/HoodieSplitNumberAssigner.java
index a0d2b5db24a8..005db4f3f451 100644
---
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/assign/HoodieSplitNumberAssigner.java
+++
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/split/assign/HoodieSplitNumberAssigner.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.hudi.source.assign;
+package org.apache.hudi.source.split.assign;
import org.apache.hudi.source.split.HoodieSourceSplit;
diff --git
a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/enumerator/TestHoodieContinuousSplitEnumerator.java
b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/enumerator/TestHoodieContinuousSplitEnumerator.java
index 6adfa2bfaf66..4045676fd05f 100644
---
a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/enumerator/TestHoodieContinuousSplitEnumerator.java
+++
b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/enumerator/TestHoodieContinuousSplitEnumerator.java
@@ -22,7 +22,7 @@ import org.apache.hudi.common.util.Option;
import org.apache.hudi.configuration.FlinkOptions;
import org.apache.hudi.metrics.FlinkStreamReadMetrics;
import org.apache.hudi.source.HoodieScanContext;
-import org.apache.hudi.source.assign.HoodieSplitNumberAssigner;
+import org.apache.hudi.source.split.assign.HoodieSplitNumberAssigner;
import org.apache.hudi.source.split.DefaultHoodieSplitProvider;
import org.apache.hudi.source.split.HoodieContinuousSplitBatch;
import org.apache.hudi.source.split.HoodieContinuousSplitDiscover;
diff --git
a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/enumerator/TestHoodieStaticSplitEnumerator.java
b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/enumerator/TestHoodieStaticSplitEnumerator.java
index 981473bcfab8..4d081eb8b758 100644
---
a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/enumerator/TestHoodieStaticSplitEnumerator.java
+++
b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/enumerator/TestHoodieStaticSplitEnumerator.java
@@ -19,7 +19,7 @@
package org.apache.hudi.source.enumerator;
import org.apache.hudi.common.util.Option;
-import org.apache.hudi.source.assign.HoodieSplitNumberAssigner;
+import org.apache.hudi.source.split.assign.HoodieSplitNumberAssigner;
import org.apache.hudi.source.split.DefaultHoodieSplitProvider;
import org.apache.hudi.source.split.HoodieSourceSplit;
import org.apache.hudi.source.split.SplitRequestEvent;
diff --git
a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/split/TestDefaultHoodieSplitProvider.java
b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/split/TestDefaultHoodieSplitProvider.java
index 516df64976ef..5571e471819c 100644
---
a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/split/TestDefaultHoodieSplitProvider.java
+++
b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/split/TestDefaultHoodieSplitProvider.java
@@ -20,7 +20,9 @@ package org.apache.hudi.source.split;
import org.apache.hudi.common.util.Option;
-import org.apache.hudi.source.assign.HoodieSplitNumberAssigner;
+import org.apache.hudi.source.split.assign.HoodieSplitBucketAssigner;
+import org.apache.hudi.source.split.assign.HoodieSplitNumberAssigner;
+import org.apache.hudi.source.split.assign.DefaultHoodieSplitAssigner;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
@@ -540,8 +542,8 @@ public class TestDefaultHoodieSplitProvider {
@Test
public void testGetNextWithDefaultAssigner() {
// Test with DefaultHoodieSplitAssigner instead of NumberAssigner
- org.apache.hudi.source.assign.DefaultHoodieSplitAssigner assigner =
- new org.apache.hudi.source.assign.DefaultHoodieSplitAssigner(3);
+ DefaultHoodieSplitAssigner assigner =
+ new DefaultHoodieSplitAssigner(3);
DefaultHoodieSplitProvider provider = new
DefaultHoodieSplitProvider(assigner);
List<HoodieSourceSplit> splits = new ArrayList<>();
@@ -561,8 +563,8 @@ public class TestDefaultHoodieSplitProvider {
@Test
public void testGetNextWithBucketAssigner() {
// Test with HoodieSplitBucketAssigner
- org.apache.hudi.source.assign.HoodieSplitBucketAssigner assigner =
- new org.apache.hudi.source.assign.HoodieSplitBucketAssigner(4);
+ HoodieSplitBucketAssigner assigner =
+ new HoodieSplitBucketAssigner(4);
DefaultHoodieSplitProvider provider = new
DefaultHoodieSplitProvider(assigner);
// Create splits with bucket-encoded file IDs
diff --git
a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/assign/TestDefaultHoodieSplitAssigner.java
b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/split/assign/TestDefaultHoodieSplitAssigner.java
similarity index 99%
rename from
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/assign/TestDefaultHoodieSplitAssigner.java
rename to
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/split/assign/TestDefaultHoodieSplitAssigner.java
index f3aa66da80ee..26f236e7f004 100644
---
a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/assign/TestDefaultHoodieSplitAssigner.java
+++
b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/split/assign/TestDefaultHoodieSplitAssigner.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.hudi.source.assign;
+package org.apache.hudi.source.split.assign;
import org.apache.hudi.common.util.Option;
import org.apache.hudi.source.split.HoodieSourceSplit;
diff --git
a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/assign/TestHoodieSplitAssigners.java
b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/split/assign/TestHoodieSplitAssigners.java
similarity index 99%
rename from
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/assign/TestHoodieSplitAssigners.java
rename to
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/split/assign/TestHoodieSplitAssigners.java
index 72357c73b640..c4ddbbc08a93 100644
---
a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/assign/TestHoodieSplitAssigners.java
+++
b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/split/assign/TestHoodieSplitAssigners.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.hudi.source.assign;
+package org.apache.hudi.source.split.assign;
import org.apache.flink.configuration.Configuration;
import org.apache.hudi.common.model.HoodieTableType;
diff --git
a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/assign/TestHoodieSplitBucketAssigner.java
b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/split/assign/TestHoodieSplitBucketAssigner.java
similarity index 99%
rename from
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/assign/TestHoodieSplitBucketAssigner.java
rename to
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/split/assign/TestHoodieSplitBucketAssigner.java
index b5488e158175..2d3da5b143a3 100644
---
a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/assign/TestHoodieSplitBucketAssigner.java
+++
b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/split/assign/TestHoodieSplitBucketAssigner.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.hudi.source.assign;
+package org.apache.hudi.source.split.assign;
import org.apache.hudi.common.util.Option;
import org.apache.hudi.source.split.HoodieSourceSplit;
diff --git
a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/assign/TestHoodieSplitNumberAssigner.java
b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/split/assign/TestHoodieSplitNumberAssigner.java
similarity index 99%
rename from
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/assign/TestHoodieSplitNumberAssigner.java
rename to
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/split/assign/TestHoodieSplitNumberAssigner.java
index 8cead120e91d..ed0047d62de9 100644
---
a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/assign/TestHoodieSplitNumberAssigner.java
+++
b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/split/assign/TestHoodieSplitNumberAssigner.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.hudi.source.assign;
+package org.apache.hudi.source.split.assign;
import org.apache.hudi.common.util.Option;
import org.apache.hudi.source.split.HoodieSourceSplit;
