pgsql

Author: simenliuxing

postgresql/postgresql-sink/src/main/java/com/dtstack/flink/sql/sink/postgresql/PostgresqlSink.java

@@ -63,15 +63,12 @@ public RetractJDBCOutputFormat getOutputFormat() {
     }
 
     @Override
-    public void buildSql(String tableName, List<String> fields) {
+    public void buildSql(String scheam, String tableName, List<String> fields) {
         buildInsertSql(tableName, fields);
     }
 
     @Override
-    public String buildUpdateSql(String tableName,
-                                 List<String> fieldNames,
-                                 Map<String, List<String>> realIndexes,
-                                 List<String> fullField) {
+    public String buildUpdateSql(String schema, String tableName, List<String> fieldNames, Map<String, List<String>> realIndexes, List<String> fullField) {
         return null;
     }