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 <[email protected]>
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);
}
}
