public DeserializationSchema<Row> getDeserializationSchema() {
        return deserializationSchema;
    }
rps Record Per Second: deserialize data and out record num
core/src/main/java/com/dtstack/flink/sql/format/DeserializationMetricWrapper.java