[Feature][Connector2] Add Dingtalk Sink apache#2257

MRYOG · Aug 1, 2022 · 4497d73 · 4497d73
1 parent fd698eb
commit 4497d73
Showing 1 changed file with 29 additions and 7 deletions.
diff --git a/...r-dingtalk/src/main/java/org/apache/seatunnel/connectors/seatunnel/sink/DingTalkSink.java b/...r-dingtalk/src/main/java/org/apache/seatunnel/connectors/seatunnel/sink/DingTalkSink.java
@@ -20,6 +20,7 @@
  import org.apache.seatunnel.api.common.PrepareFailException;
  import org.apache.seatunnel.api.sink.SeaTunnelSink;
  import org.apache.seatunnel.api.sink.SinkWriter;
+ import org.apache.seatunnel.api.sink.SinkWriter.Context;
  import org.apache.seatunnel.api.table.type.SeaTunnelDataType;
  import org.apache.seatunnel.api.table.type.SeaTunnelRow;
  import org.apache.seatunnel.api.table.type.SeaTunnelRowType;
@@ -38,21 +39,42 @@
   */
  @AutoService(SeaTunnelSink.class)
  public class DingTalkSink extends AbstractSimpleSink<SeaTunnelRow, Void> {
+
    private Config pluginConfig;
    private SeaTunnelRowType seaTunnelRowType;
-   private final String CONSTANT_URL="url";
-   private final String CONSTANT_SECRET="secret";
+   private final String CONSTANT_URL = "url";
+   private final String CONSTANT_SECRET = "secret";
+
    @Override
    public String getPluginName() {
      return "DingTalk";
    }
 
    @Override
    public void prepare(Config pluginConfig) throws PrepareFailException {
-     if(pluginConfig.getIsNull(CONSTANT_URL)){
-       throw new PrepareFailException(getPluginName(), PluginType.SINK,  String.format("Config must include column : %s", CONSTANT_URL));
+     if (pluginConfig.getIsNull(CONSTANT_URL)) {
+       throw new PrepareFailException(getPluginName(), PluginType.SINK,
+           String.format("Config must include column : %s", CONSTANT_URL));
      }
-     if(pluginConfig.getIsNull(CONSTANT_SECRET)){
-       throw new PrepareFailException(getPluginName(), PluginType.SINK,  String.format("Config must include column : %s", CONSTANT_SECRET));
+     if (pluginConfig.getIsNull(CONSTANT_SECRET)) {
+       throw new PrepareFailException(getPluginName(), PluginType.SINK,
+           String.format("Config must include column : %s", CONSTANT_SECRET));
      }
-     this.pluginConfig = pluginConfig;
+     this.pluginConfig = pluginConfig;
+   }
+
+   @Override
+   public void setTypeInfo(SeaTunnelRowType seaTunnelRowType) {
+
+   }
+
+   @Override
+   public SeaTunnelDataType<SeaTunnelRow> getConsumedType() {
+     return null;
+   }
+
+   @Override
+   public AbstractSinkWriter<SeaTunnelRow, Void> createWriter(Context context) throws IOException {
+     return null;
+   }
+ }