[Feature][Connector2] Add DingTalk Source apache#2684

MRYOG · Sep 8, 2022 · a16b1d9 · a16b1d9
1 parent 13dd18b
commit a16b1d9
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...ngtalk/src/main/java/org/apache/seatunnel/connectors/seatunnel/source/DingTalkSource.java b/...ngtalk/src/main/java/org/apache/seatunnel/connectors/seatunnel/source/DingTalkSource.java
@@ -32,7 +32,7 @@
 import org.apache.seatunnel.connectors.seatunnel.common.DingTalkConstant;
 import org.apache.seatunnel.connectors.seatunnel.common.DingTalkParameter;
 import org.apache.seatunnel.connectors.seatunnel.common.DingTalkUtil;
-import org.apache.seatunnel.connectors.seatunnel.common.schema.SeatunnelSchema;
+import org.apache.seatunnel.connectors.seatunnel.common.schema.SeaTunnelSchema;
 import org.apache.seatunnel.connectors.seatunnel.common.source.AbstractSingleSplitReader;
 import org.apache.seatunnel.connectors.seatunnel.common.source.AbstractSingleSplitSource;
 import org.apache.seatunnel.connectors.seatunnel.common.source.SingleSplitReaderContext;
@@ -85,9 +85,9 @@ public void prepare(Config pluginConfig) throws PrepareFailException {
 
         if (pluginConfig.hasPath(DingTalkConstant.SCHEMA)) {
             Config schema = pluginConfig.getConfig(DingTalkConstant.SCHEMA);
-            this.rowType = SeatunnelSchema.buildWithConfig(schema).getSeaTunnelRowType();
+            this.rowType = SeaTunnelSchema.buildWithConfig(schema).getSeaTunnelRowType();
         } else {
-            this.rowType = SeatunnelSchema.buildSimpleTextSchema();
+            this.rowType = SeaTunnelSchema.buildSimpleTextSchema();
         }
     }