Class TestingDeserializationContext

  • All Implemented Interfaces:
    org.apache.flink.api.common.serialization.DeserializationSchema.InitializationContext

    public class TestingDeserializationContext
    extends Object
    implements org.apache.flink.api.common.serialization.DeserializationSchema.InitializationContext
    An implementation of DeserializationSchema.InitializationContext for test.
    • Constructor Detail

      • TestingDeserializationContext

        public TestingDeserializationContext()
    • Method Detail

      • getMetricGroup

        public org.apache.flink.metrics.MetricGroup getMetricGroup()
        Specified by:
        getMetricGroup in interface org.apache.flink.api.common.serialization.DeserializationSchema.InitializationContext
      • getUserCodeClassLoader

        public org.apache.flink.util.UserCodeClassLoader getUserCodeClassLoader()
        Specified by:
        getUserCodeClassLoader in interface org.apache.flink.api.common.serialization.DeserializationSchema.InitializationContext