@Override
    public DynamicTableSink copy() {
        HiveTableSink sink =
                new HiveTableSink(
                        flinkConf,
                        jobConf,
                        identifier,
                        catalogTable,
                        configuredParallelism,
                        inlongMetric,
                        auditHostAndPorts,
                        dirtyOptions,
                        dirtySink,
                        schemaUpdatePolicy,
                        partitionPolicy,
                        partitionField,
                        timePattern,
                        sinkMultipleEnable,
                        inputFormat,
                        outputFormat,
                        serializationLib);
        sink.staticPartitionSpec = staticPartitionSpec;
        sink.overwrite = overwrite;
        sink.dynamicGrouping = dynamicGrouping;
        return sink;
    }
Table sink to write to Hive tables.
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/hive/src/main/java/org/apache/inlong/sort/hive/HiveTableSink.java