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();
}
}