You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by ki...@apache.org on 2022/10/14 10:07:38 UTC
[incubator-seatunnel] branch dev updated: [Improve][Translation][Spark] Rename `SeatunnelInputPartitionReader` to `SeaTunnelInputPartitionReader` (#3084)
This is an automated email from the ASF dual-hosted git repository.
kirs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 758db6e8c [Improve][Translation][Spark] Rename `SeatunnelInputPartitionReader` to `SeaTunnelInputPartitionReader` (#3084)
758db6e8c is described below
commit 758db6e8ca663ec524286c76cb7a4ddf6cc13eb6
Author: TyrantLucifer <Ty...@gmail.com>
AuthorDate: Fri Oct 14 18:07:31 2022 +0800
[Improve][Translation][Spark] Rename `SeatunnelInputPartitionReader` to `SeaTunnelInputPartitionReader` (#3084)
---
...elInputPartitionReader.java => SeaTunnelInputPartitionReader.java} | 4 ++--
.../seatunnel/translation/spark/source/batch/BatchPartition.java | 4 ++--
.../seatunnel/translation/spark/source/micro/MicroBatchPartition.java | 4 ++--
3 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-2.4/src/main/java/org/apache/seatunnel/translation/spark/source/SeatunnelInputPartitionReader.java b/seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-2.4/src/main/java/org/apache/seatunnel/translation/spark/source/SeaTunnelInputPartitionReader.java
similarity index 92%
rename from seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-2.4/src/main/java/org/apache/seatunnel/translation/spark/source/SeatunnelInputPartitionReader.java
rename to seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-2.4/src/main/java/org/apache/seatunnel/translation/spark/source/SeaTunnelInputPartitionReader.java
index 97a6cdfe3..ef2ca3ac3 100644
--- a/seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-2.4/src/main/java/org/apache/seatunnel/translation/spark/source/SeatunnelInputPartitionReader.java
+++ b/seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-2.4/src/main/java/org/apache/seatunnel/translation/spark/source/SeaTunnelInputPartitionReader.java
@@ -24,11 +24,11 @@ import org.apache.spark.sql.sources.v2.reader.InputPartitionReader;
import java.io.IOException;
-public class SeatunnelInputPartitionReader implements InputPartitionReader<InternalRow> {
+public class SeaTunnelInputPartitionReader implements InputPartitionReader<InternalRow> {
private final ParallelBatchPartitionReader partitionReader;
- public SeatunnelInputPartitionReader(ParallelBatchPartitionReader partitionReader) {
+ public SeaTunnelInputPartitionReader(ParallelBatchPartitionReader partitionReader) {
this.partitionReader = partitionReader;
}
diff --git a/seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-2.4/src/main/java/org/apache/seatunnel/translation/spark/source/batch/BatchPartition.java b/seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-2.4/src/main/java/org/apache/seatunnel/translation/spark/source/batch/BatchPartition.java
index 1acaf879a..fdcba83ff 100644
--- a/seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-2.4/src/main/java/org/apache/seatunnel/translation/spark/source/batch/BatchPartition.java
+++ b/seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-2.4/src/main/java/org/apache/seatunnel/translation/spark/source/batch/BatchPartition.java
@@ -22,7 +22,7 @@ import org.apache.seatunnel.api.source.SupportCoordinate;
import org.apache.seatunnel.api.table.type.SeaTunnelRow;
import org.apache.seatunnel.translation.spark.common.source.batch.CoordinatedBatchPartitionReader;
import org.apache.seatunnel.translation.spark.common.source.batch.ParallelBatchPartitionReader;
-import org.apache.seatunnel.translation.spark.source.SeatunnelInputPartitionReader;
+import org.apache.seatunnel.translation.spark.source.SeaTunnelInputPartitionReader;
import org.apache.spark.sql.catalyst.InternalRow;
import org.apache.spark.sql.sources.v2.reader.InputPartition;
@@ -47,6 +47,6 @@ public class BatchPartition implements InputPartition<InternalRow> {
} else {
partitionReader = new ParallelBatchPartitionReader(source, parallelism, subtaskId);
}
- return new SeatunnelInputPartitionReader(partitionReader);
+ return new SeaTunnelInputPartitionReader(partitionReader);
}
}
diff --git a/seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-2.4/src/main/java/org/apache/seatunnel/translation/spark/source/micro/MicroBatchPartition.java b/seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-2.4/src/main/java/org/apache/seatunnel/translation/spark/source/micro/MicroBatchPartition.java
index 0ee95b3b4..96cff6e7a 100644
--- a/seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-2.4/src/main/java/org/apache/seatunnel/translation/spark/source/micro/MicroBatchPartition.java
+++ b/seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-2.4/src/main/java/org/apache/seatunnel/translation/spark/source/micro/MicroBatchPartition.java
@@ -23,7 +23,7 @@ import org.apache.seatunnel.api.table.type.SeaTunnelRow;
import org.apache.seatunnel.translation.spark.common.source.batch.ParallelBatchPartitionReader;
import org.apache.seatunnel.translation.spark.common.source.micro.CoordinatedMicroBatchPartitionReader;
import org.apache.seatunnel.translation.spark.common.source.micro.ParallelMicroBatchPartitionReader;
-import org.apache.seatunnel.translation.spark.source.SeatunnelInputPartitionReader;
+import org.apache.seatunnel.translation.spark.source.SeaTunnelInputPartitionReader;
import org.apache.spark.sql.catalyst.InternalRow;
import org.apache.spark.sql.sources.v2.reader.InputPartition;
@@ -65,6 +65,6 @@ public class MicroBatchPartition implements InputPartition<InternalRow> {
} else {
partitionReader = new ParallelMicroBatchPartitionReader(source, parallelism, subtaskId, checkpointId, checkpointInterval, checkpointPath, hdfsRoot, hdfsUser);
}
- return new SeatunnelInputPartitionReader(partitionReader);
+ return new SeaTunnelInputPartitionReader(partitionReader);
}
}