diff --git a/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/copy/CopyFieldTransform.java b/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/copy/CopyFieldTransform.java index e49f13ba6d0..e15df5b7f49 100644 --- a/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/copy/CopyFieldTransform.java +++ b/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/copy/CopyFieldTransform.java @@ -25,12 +25,9 @@ import org.apache.seatunnel.api.table.type.SeaTunnelDataType; import org.apache.seatunnel.api.table.type.SeaTunnelRow; import org.apache.seatunnel.api.table.type.SeaTunnelRowType; -import org.apache.seatunnel.api.transform.SeaTunnelTransform; import org.apache.seatunnel.transform.common.MultipleFieldOutputTransform; import org.apache.seatunnel.transform.common.SeaTunnelRowAccessor; -import com.google.auto.service.AutoService; - import java.lang.reflect.Array; import java.util.ArrayList; import java.util.HashMap; @@ -39,7 +36,6 @@ import java.util.Map; import java.util.stream.Collectors; -@AutoService(SeaTunnelTransform.class) public class CopyFieldTransform extends MultipleFieldOutputTransform { public static final String PLUGIN_NAME = "Copy"; diff --git a/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/fieldmapper/FieldMapperTransform.java b/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/fieldmapper/FieldMapperTransform.java index 9e9c7615f28..4eed0b72e10 100644 --- a/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/fieldmapper/FieldMapperTransform.java +++ b/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/fieldmapper/FieldMapperTransform.java @@ -26,7 +26,6 @@ import org.apache.seatunnel.api.table.catalog.TableSchema; import org.apache.seatunnel.api.table.type.SeaTunnelRow; import org.apache.seatunnel.api.table.type.SeaTunnelRowType; -import org.apache.seatunnel.api.transform.SeaTunnelTransform; import org.apache.seatunnel.transform.common.AbstractCatalogSupportTransform; import org.apache.seatunnel.transform.exception.FieldMapperTransformErrorCode; import org.apache.seatunnel.transform.exception.FieldMapperTransformException; @@ -34,7 +33,6 @@ import org.apache.commons.collections4.CollectionUtils; -import com.google.auto.service.AutoService; import com.google.common.collect.Lists; import lombok.NonNull; import lombok.extern.slf4j.Slf4j; @@ -45,7 +43,6 @@ import java.util.stream.Collectors; @Slf4j -@AutoService(SeaTunnelTransform.class) public class FieldMapperTransform extends AbstractCatalogSupportTransform { public static String PLUGIN_NAME = "FieldMapper"; private FieldMapperTransformConfig config; diff --git a/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/filter/FilterFieldTransform.java b/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/filter/FilterFieldTransform.java index 5e4198e2d19..615b749c6d5 100644 --- a/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/filter/FilterFieldTransform.java +++ b/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/filter/FilterFieldTransform.java @@ -26,14 +26,12 @@ import org.apache.seatunnel.api.table.catalog.TableSchema; import org.apache.seatunnel.api.table.type.SeaTunnelRow; import org.apache.seatunnel.api.table.type.SeaTunnelRowType; -import org.apache.seatunnel.api.transform.SeaTunnelTransform; import org.apache.seatunnel.transform.common.AbstractCatalogSupportTransform; import org.apache.seatunnel.transform.exception.FilterFieldTransformErrorCode; import org.apache.seatunnel.transform.exception.TransformException; import org.apache.commons.collections4.CollectionUtils; -import com.google.auto.service.AutoService; import lombok.NonNull; import lombok.extern.slf4j.Slf4j; @@ -43,7 +41,6 @@ import java.util.stream.Collectors; @Slf4j -@AutoService(SeaTunnelTransform.class) public class FilterFieldTransform extends AbstractCatalogSupportTransform { public static final String PLUGIN_NAME = "Filter"; private int[] inputValueIndex; diff --git a/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/filterrowkind/FilterRowKindTransform.java b/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/filterrowkind/FilterRowKindTransform.java index 3e085f7d0df..2140d8de008 100644 --- a/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/filterrowkind/FilterRowKindTransform.java +++ b/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/filterrowkind/FilterRowKindTransform.java @@ -21,12 +21,10 @@ import org.apache.seatunnel.api.table.catalog.CatalogTable; import org.apache.seatunnel.api.table.type.RowKind; import org.apache.seatunnel.api.table.type.SeaTunnelRow; -import org.apache.seatunnel.api.transform.SeaTunnelTransform; import org.apache.seatunnel.common.exception.CommonErrorCode; import org.apache.seatunnel.common.exception.SeaTunnelRuntimeException; import org.apache.seatunnel.transform.common.FilterRowTransform; -import com.google.auto.service.AutoService; import lombok.NonNull; import lombok.ToString; @@ -35,7 +33,6 @@ import java.util.Set; @ToString(of = {"includeKinds", "excludeKinds"}) -@AutoService(SeaTunnelTransform.class) public class FilterRowKindTransform extends FilterRowTransform { public static String PLUGIN_NAME = "FilterRowKind"; diff --git a/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/replace/ReplaceTransform.java b/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/replace/ReplaceTransform.java index 9baa76aeefc..b72ad39c87d 100644 --- a/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/replace/ReplaceTransform.java +++ b/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/replace/ReplaceTransform.java @@ -21,19 +21,16 @@ import org.apache.seatunnel.api.table.catalog.CatalogTable; import org.apache.seatunnel.api.table.catalog.Column; import org.apache.seatunnel.api.table.type.SeaTunnelRowType; -import org.apache.seatunnel.api.transform.SeaTunnelTransform; import org.apache.seatunnel.transform.common.SeaTunnelRowAccessor; import org.apache.seatunnel.transform.common.SingleFieldOutputTransform; import org.apache.commons.collections4.CollectionUtils; -import com.google.auto.service.AutoService; import lombok.NonNull; import java.util.List; import java.util.stream.Collectors; -@AutoService(SeaTunnelTransform.class) public class ReplaceTransform extends SingleFieldOutputTransform { private ReadonlyConfig config; private int inputFieldIndex; diff --git a/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/split/SplitTransform.java b/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/split/SplitTransform.java index 191792779a9..7132388f8e2 100644 --- a/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/split/SplitTransform.java +++ b/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/split/SplitTransform.java @@ -22,18 +22,15 @@ import org.apache.seatunnel.api.table.catalog.PhysicalColumn; import org.apache.seatunnel.api.table.type.BasicType; import org.apache.seatunnel.api.table.type.SeaTunnelRowType; -import org.apache.seatunnel.api.transform.SeaTunnelTransform; import org.apache.seatunnel.transform.common.MultipleFieldOutputTransform; import org.apache.seatunnel.transform.common.SeaTunnelRowAccessor; -import com.google.auto.service.AutoService; import lombok.NonNull; import java.util.Arrays; import java.util.List; import java.util.stream.Collectors; -@AutoService(SeaTunnelTransform.class) public class SplitTransform extends MultipleFieldOutputTransform { private SplitTransformConfig splitTransformConfig; private int splitFieldIndex; diff --git a/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/SQLTransform.java b/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/SQLTransform.java index c59f0221d3c..fca94e5af82 100644 --- a/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/SQLTransform.java +++ b/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/SQLTransform.java @@ -31,11 +31,9 @@ import org.apache.seatunnel.api.table.type.SeaTunnelDataType; import org.apache.seatunnel.api.table.type.SeaTunnelRow; import org.apache.seatunnel.api.table.type.SeaTunnelRowType; -import org.apache.seatunnel.api.transform.SeaTunnelTransform; import org.apache.seatunnel.transform.common.AbstractCatalogSupportTransform; import org.apache.seatunnel.transform.sql.SQLEngineFactory.EngineType; -import com.google.auto.service.AutoService; import lombok.NonNull; import lombok.extern.slf4j.Slf4j; @@ -45,7 +43,6 @@ import static org.apache.seatunnel.transform.sql.SQLEngineFactory.EngineType.ZETA; @Slf4j -@AutoService(SeaTunnelTransform.class) public class SQLTransform extends AbstractCatalogSupportTransform { public static final String PLUGIN_NAME = "Sql";