[feat-#1487][iceberg]add iceberg writer (#1489)

Author: mggger

chunjun-connectors/chunjun-connector-iceberg/pom.xml

@@ -31,40 +31,53 @@
 	<artifactId>chunjun-connector-iceberg</artifactId>
 	<name>ChunJun : Connectors : Iceberg</name>
 
-	<dependencies>
+	<properties>
+		<hadoop.version>2.7.5</hadoop.version>
+		<iceberg.version>0.13.1</iceberg.version>
+	</properties>
+
 
-		<!-- flink iceberg connector start  -->
-<!--		<dependency>-->
-<!--			<groupId>org.apache.iceberg</groupId>-->
-<!--			<artifactId>iceberg-flink-1.12</artifactId>-->
-<!--			<version>0.13.2</version>-->
-<!--			<exclusions>-->
-<!--				<exclusion>-->
-<!--					<artifactId>avro</artifactId>-->
-<!--					<groupId>org.apache.avro</groupId>-->
-<!--				</exclusion>-->
-<!--			</exclusions>-->
-<!--		</dependency>-->
+	<dependencies>
 		<dependency>
 			<groupId>org.apache.iceberg</groupId>
-			<artifactId>iceberg-flink-runtime-1.12</artifactId>
-			<version>0.13.2</version>
+			<artifactId>iceberg-flink-runtime-1.13</artifactId>
+			<version>${iceberg.version}</version>
+			<exclusions>
+				<exclusion>
+					<groupId>org.apache.hadoop</groupId>
+					<artifactId>hadoop-hdfs</artifactId>
+				</exclusion>
+
+				<exclusion>
+					<groupId>org.apache.hadoop</groupId>
+					<artifactId>hadoop-common</artifactId>
+				</exclusion>
+
+				<exclusion>
+					<groupId>org.apache.hadoop</groupId>
+					<artifactId>hadoop-client</artifactId>
+				</exclusion>
+			</exclusions>
+		</dependency>
+
+		<dependency>
+			<groupId>org.apache.hadoop</groupId>
+			<artifactId>hadoop-hdfs</artifactId>
+			<version>${hadoop.version}</version>
 		</dependency>
 
-<!--		<dependency>-->
-<!--			<groupId>org.apache.hadoop</groupId>-->
-<!--			<artifactId>hadoop-client</artifactId>-->
-<!--			<version>2.7.3</version>-->
-<!--			<exclusions>-->
-<!--				<exclusion>-->
-<!--					<artifactId>avro</artifactId>-->
-<!--					<groupId>org.apache.avro</groupId>-->
-<!--				</exclusion>-->
-<!--			</exclusions>-->
-<!--		</dependency>-->
+		<dependency>
+			<groupId>org.apache.hadoop</groupId>
+			<artifactId>hadoop-common</artifactId>
+			<version>${hadoop.version}</version>
+		</dependency>
 
+		<dependency>
+			<groupId>org.apache.hadoop</groupId>
+			<artifactId>hadoop-client</artifactId>
+			<version>${hadoop.version}</version>
+		</dependency>
 
-		<!-- flink iceberg connector end  -->
 	</dependencies>
 
 	<build>

chunjun-connectors/chunjun-connector-iceberg/src/main/java/com/dtstack/chunjun/connector/iceberg/conf/IcebergConf.java

@@ -0,0 +1,69 @@
+package com.dtstack.chunjun.connector.iceberg.conf;
+
+import com.dtstack.chunjun.conf.ChunJunCommonConf;
+import com.dtstack.chunjun.sink.WriteMode;
+
+import java.util.HashMap;
+import java.util.Map;
+
+public class IcebergConf extends ChunJunCommonConf {
+    private String warehouse;
+
+    private String uri;
+
+    private Map<String, Object> hadoopConfig = new HashMap<>();
+
+    private String database;
+
+    private String table;
+
+    private String writeMode = WriteMode.APPEND.name();
+
+    public void setDatabase(String database) {
+        this.database = database;
+    }
+
+    public String getDatabase() {
+        return database;
+    }
+
+    public void setTable(String table) {
+        this.table = table;
+    }
+
+    public String getTable() {
+        return table;
+    }
+
+    public void setWarehouse(String warehouse) {
+        this.warehouse = warehouse;
+    }
+
+    public String getWarehouse() {
+        return warehouse;
+    }
+
+    public void setUri(String uri) {
+        this.uri = uri;
+    }
+
+    public String getUri() {
+        return uri;
+    }
+
+    public void setHadoopConfig(Map<String, Object> hadoopConfig) {
+        this.hadoopConfig = hadoopConfig;
+    }
+
+    public Map<String, Object> getHadoopConfig() {
+        return hadoopConfig;
+    }
+
+    public String getWriteMode() {
+        return writeMode;
+    }
+
+    public void setWriteMode(String writeMode) {
+        this.writeMode = writeMode;
+    }
+}