private SerializationSchema<RowData> createSerialization(
            Context context,
            EncodingFormat<SerializationSchema<RowData>> format,
            DataType physicalDataType) {
        return format.createRuntimeEncoder(context, physicalDataType);
    }
The parameters collection for tubemq producer.
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/table/TubeMQTableSink.java