flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/StreamingServerTypeUtil.java [45:54]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public static TableSchema normalizeTableSchema(TableSchema schema) {
        Builder physicalSchemaBuilder = TableSchema.builder();
        schema.getTableColumns().forEach((c) -> {
            if (c.isPhysical()) {
                DataType type = DataTypeUtils.transform(c.getType(), new TypeTransformation[]{TypeTransformations.timeToSqlTypes()});
                physicalSchemaBuilder.field(c.getName(), type);
            }
        });
        return physicalSchemaBuilder.build();
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/JdbcTypeUtil.java [49:58]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public static TableSchema normalizeTableSchema(TableSchema schema) {
        Builder physicalSchemaBuilder = TableSchema.builder();
        schema.getTableColumns().forEach((c) -> {
            if (c.isPhysical()) {
                DataType type = DataTypeUtils.transform(c.getType(), new TypeTransformation[]{TypeTransformations.timeToSqlTypes()});
                physicalSchemaBuilder.field(c.getName(), type);
            }
        });
        return physicalSchemaBuilder.build();
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -