You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by ty...@apache.org on 2023/01/12 01:27:04 UTC
[incubator-seatunnel] branch dev updated (e24843515 -> 29f824608)
This is an automated email from the ASF dual-hosted git repository.
tyrantlucifer pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
from e24843515 [Improve][Connector-V2][Iceberg] Unified exception for iceberg source connector (#3677)
add 29f824608 [Improve][Core][API] Remove old version apis (#3920)
No new revisions were added by this update.
Summary of changes:
.github/workflows/backend.yml | 1 -
pom.xml | 1 -
seatunnel-apis/pom.xml | 36 ---
seatunnel-apis/seatunnel-api-base/pom.xml | 40 ---
.../apache/seatunnel/apis/base/api/BaseSink.java | 27 --
.../apache/seatunnel/apis/base/api/BaseSource.java | 28 --
.../seatunnel/apis/base/api/BaseTransform.java | 28 --
.../seatunnel/apis/base/command/Command.java | 35 ---
.../seatunnel/apis/base/command/CommandArgs.java | 24 --
.../apis/base/command/CommandBuilder.java | 25 --
.../apache/seatunnel/apis/base/env/Execution.java | 46 ---
.../apache/seatunnel/apis/base/env/RuntimeEnv.java | 47 ---
.../apache/seatunnel/apis/base/plugin/Plugin.java | 83 -----
.../apis/base/plugin/PluginClosedException.java | 43 ---
seatunnel-apis/seatunnel-api-flink/pom.xml | 129 --------
.../org/apache/seatunnel/flink/BaseFlinkSink.java | 27 --
.../apache/seatunnel/flink/BaseFlinkSource.java | 28 --
.../apache/seatunnel/flink/BaseFlinkTransform.java | 31 --
.../apache/seatunnel/flink/FlinkEnvironment.java | 344 ---------------------
.../seatunnel/flink/batch/FlinkBatchExecution.java | 121 --------
.../seatunnel/flink/batch/FlinkBatchSink.java | 32 --
.../seatunnel/flink/batch/FlinkBatchSource.java | 32 --
.../seatunnel/flink/batch/FlinkBatchTransform.java | 33 --
.../apache/seatunnel/flink/enums/FormatType.java | 51 ---
.../flink/stream/FlinkStreamExecution.java | 104 -------
.../seatunnel/flink/stream/FlinkStreamSink.java | 33 --
.../seatunnel/flink/stream/FlinkStreamSource.java | 32 --
.../flink/stream/FlinkStreamTransform.java | 32 --
.../apache/seatunnel/flink/util/ConfigKeyName.java | 48 ---
.../seatunnel/flink/util/EnvironmentUtil.java | 102 ------
.../apache/seatunnel/flink/util/SchemaUtil.java | 238 --------------
.../org/apache/seatunnel/flink/util/TableUtil.java | 64 ----
seatunnel-apis/seatunnel-api-spark/pom.xml | 74 -----
.../org/apache/seatunnel/spark/BaseSparkSink.java | 46 ---
.../apache/seatunnel/spark/BaseSparkSource.java | 43 ---
.../apache/seatunnel/spark/BaseSparkTransform.java | 46 ---
.../apache/seatunnel/spark/SparkEnvironment.java | 191 ------------
.../seatunnel/spark/batch/SparkBatchExecution.java | 72 -----
.../seatunnel/spark/batch/SparkBatchSink.java | 30 --
.../seatunnel/spark/batch/SparkBatchSource.java | 31 --
.../StructuredStreamingExecution.java | 74 -----
.../structuredstream/StructuredStreamingSink.java | 31 --
.../StructuredStreamingSource.java | 31 --
.../seatunnel/spark/utils/SparkStructTypeUtil.java | 109 -------
.../spark/stream/SparkStreamingExecution.scala | 79 -----
.../spark/stream/SparkStreamingSink.scala | 25 --
.../spark/stream/SparkStreamingSource.scala | 43 ---
tools/dependencies/known-dependencies.txt | 1 -
48 files changed, 2871 deletions(-)
delete mode 100644 seatunnel-apis/pom.xml
delete mode 100644 seatunnel-apis/seatunnel-api-base/pom.xml
delete mode 100644 seatunnel-apis/seatunnel-api-base/src/main/java/org/apache/seatunnel/apis/base/api/BaseSink.java
delete mode 100644 seatunnel-apis/seatunnel-api-base/src/main/java/org/apache/seatunnel/apis/base/api/BaseSource.java
delete mode 100644 seatunnel-apis/seatunnel-api-base/src/main/java/org/apache/seatunnel/apis/base/api/BaseTransform.java
delete mode 100644 seatunnel-apis/seatunnel-api-base/src/main/java/org/apache/seatunnel/apis/base/command/Command.java
delete mode 100644 seatunnel-apis/seatunnel-api-base/src/main/java/org/apache/seatunnel/apis/base/command/CommandArgs.java
delete mode 100644 seatunnel-apis/seatunnel-api-base/src/main/java/org/apache/seatunnel/apis/base/command/CommandBuilder.java
delete mode 100644 seatunnel-apis/seatunnel-api-base/src/main/java/org/apache/seatunnel/apis/base/env/Execution.java
delete mode 100644 seatunnel-apis/seatunnel-api-base/src/main/java/org/apache/seatunnel/apis/base/env/RuntimeEnv.java
delete mode 100644 seatunnel-apis/seatunnel-api-base/src/main/java/org/apache/seatunnel/apis/base/plugin/Plugin.java
delete mode 100644 seatunnel-apis/seatunnel-api-base/src/main/java/org/apache/seatunnel/apis/base/plugin/PluginClosedException.java
delete mode 100644 seatunnel-apis/seatunnel-api-flink/pom.xml
delete mode 100644 seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/BaseFlinkSink.java
delete mode 100644 seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/BaseFlinkSource.java
delete mode 100644 seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/BaseFlinkTransform.java
delete mode 100644 seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/FlinkEnvironment.java
delete mode 100644 seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/batch/FlinkBatchExecution.java
delete mode 100644 seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/batch/FlinkBatchSink.java
delete mode 100644 seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/batch/FlinkBatchSource.java
delete mode 100644 seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/batch/FlinkBatchTransform.java
delete mode 100644 seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/enums/FormatType.java
delete mode 100644 seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/stream/FlinkStreamExecution.java
delete mode 100644 seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/stream/FlinkStreamSink.java
delete mode 100644 seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/stream/FlinkStreamSource.java
delete mode 100644 seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/stream/FlinkStreamTransform.java
delete mode 100644 seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/util/ConfigKeyName.java
delete mode 100644 seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/util/EnvironmentUtil.java
delete mode 100644 seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/util/SchemaUtil.java
delete mode 100644 seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/util/TableUtil.java
delete mode 100644 seatunnel-apis/seatunnel-api-spark/pom.xml
delete mode 100644 seatunnel-apis/seatunnel-api-spark/src/main/java/org/apache/seatunnel/spark/BaseSparkSink.java
delete mode 100644 seatunnel-apis/seatunnel-api-spark/src/main/java/org/apache/seatunnel/spark/BaseSparkSource.java
delete mode 100644 seatunnel-apis/seatunnel-api-spark/src/main/java/org/apache/seatunnel/spark/BaseSparkTransform.java
delete mode 100644 seatunnel-apis/seatunnel-api-spark/src/main/java/org/apache/seatunnel/spark/SparkEnvironment.java
delete mode 100644 seatunnel-apis/seatunnel-api-spark/src/main/java/org/apache/seatunnel/spark/batch/SparkBatchExecution.java
delete mode 100644 seatunnel-apis/seatunnel-api-spark/src/main/java/org/apache/seatunnel/spark/batch/SparkBatchSink.java
delete mode 100644 seatunnel-apis/seatunnel-api-spark/src/main/java/org/apache/seatunnel/spark/batch/SparkBatchSource.java
delete mode 100644 seatunnel-apis/seatunnel-api-spark/src/main/java/org/apache/seatunnel/spark/structuredstream/StructuredStreamingExecution.java
delete mode 100644 seatunnel-apis/seatunnel-api-spark/src/main/java/org/apache/seatunnel/spark/structuredstream/StructuredStreamingSink.java
delete mode 100644 seatunnel-apis/seatunnel-api-spark/src/main/java/org/apache/seatunnel/spark/structuredstream/StructuredStreamingSource.java
delete mode 100644 seatunnel-apis/seatunnel-api-spark/src/main/java/org/apache/seatunnel/spark/utils/SparkStructTypeUtil.java
delete mode 100644 seatunnel-apis/seatunnel-api-spark/src/main/scala/org/apache/seatunnel/spark/stream/SparkStreamingExecution.scala
delete mode 100644 seatunnel-apis/seatunnel-api-spark/src/main/scala/org/apache/seatunnel/spark/stream/SparkStreamingSink.scala
delete mode 100644 seatunnel-apis/seatunnel-api-spark/src/main/scala/org/apache/seatunnel/spark/stream/SparkStreamingSource.scala