Class TestingDeserializationContext
- java.lang.Object
-
- org.apache.flink.connector.testutils.source.deserialization.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 ofDeserializationSchema.InitializationContextfor test.
-
-
Constructor Summary
Constructors Constructor Description TestingDeserializationContext()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.flink.metrics.MetricGroupgetMetricGroup()org.apache.flink.util.UserCodeClassLoadergetUserCodeClassLoader()
-
-
-
Method Detail
-
getMetricGroup
public org.apache.flink.metrics.MetricGroup getMetricGroup()
- Specified by:
getMetricGroupin interfaceorg.apache.flink.api.common.serialization.DeserializationSchema.InitializationContext
-
getUserCodeClassLoader
public org.apache.flink.util.UserCodeClassLoader getUserCodeClassLoader()
- Specified by:
getUserCodeClassLoaderin interfaceorg.apache.flink.api.common.serialization.DeserializationSchema.InitializationContext
-
-