DataType getFormatDataType() {
        TableSchema.Builder builder = TableSchema.builder();
        schema.getTableColumns()
                .forEach(
                        column -> {
                            if (!partitionKeys.contains(column.getName())) {
                                builder.add(column);
                            }
                        });
        return builder.build().toRowDataType();
    }
Abstract File system table for providing some common methods.
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/filesystem/src/main/java/org/apache/inlong/sort/filesystem/AbstractFileSystemTable.java