protected DeserializationMetricWrapper createDeserializationMetricWrapper(KafkaSourceTableInfo kafkaSourceTableInfo,
                                                                              TypeInformation<Row> typeInformation,
                                                                              Calculate calculate) {
        return new KafkaDeserializationMetricWrapper(typeInformation,
                DeserializationSchemaFactory.createDeserializationSchema(kafkaSourceTableInfo, typeInformation),
                calculate,
                DirtyDataManager.newInstance(kafkaSourceTableInfo.getDirtyProperties()));
    }
company: www.dtstack.com
@author: toutian
create: 2019/12/24
kafka-base/kafka-base-source/src/main/java/com/dtstack/flink/sql/source/kafka/AbstractKafkaConsumerFactory.java