public AdbpgDynamicTableSink()

in flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/AdbpgDynamicTableSink.java [46:65]


    public AdbpgDynamicTableSink(
            ReadableConfig config,
            TableSchema tableSchema
    ) {
        this.config = config;
        this.tableSchema = tableSchema;
        this.fieldNum = tableSchema.getFieldCount();
        this.fieldNamesStr = new String[fieldNum];
        for (int i = 0; i < fieldNum; i++) {
            this.fieldNamesStr[i] = tableSchema.getFieldName(i).get();
        }
        this.keyFields =
                tableSchema.getPrimaryKey()
                        .map(pk -> pk.getColumns().toArray(new String[0]))
                        .orElse(null);
        this.lts = new LogicalType[fieldNum];
        for (int i = 0; i < fieldNum; i++) {
            this.lts[i] = tableSchema.getFieldDataType(i).get().getLogicalType();
        }
    }