@Override
                public void flush() throws IOException {
                    writer.flush();
                }
Project row to non-partition fields.
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/filesystem/src/main/java/org/apache/inlong/sort/filesystem/FileSystemTableSink.java