Class TestingDeserializationContext
- java.lang.Object
-
- org.apache.flink.connector.testutils.source.deserialization.TestingDeserializationContext
-
- All Implemented Interfaces:
DeserializationSchema.InitializationContext
public class TestingDeserializationContext extends Object implements DeserializationSchema.InitializationContext
An implementation ofDeserializationSchema.InitializationContext
for test.
-
-
Constructor Summary
Constructors Constructor Description TestingDeserializationContext()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description MetricGroup
getMetricGroup()
Returns the metric group for the parallel subtask of the source that runs thisDeserializationSchema
.UserCodeClassLoader
getUserCodeClassLoader()
Gets theUserCodeClassLoader
to load classes that are not in system's classpath, but are part of the jar file of a user job.
-
-
-
Method Detail
-
getMetricGroup
public MetricGroup getMetricGroup()
Description copied from interface:DeserializationSchema.InitializationContext
Returns the metric group for the parallel subtask of the source that runs thisDeserializationSchema
.Instances of this class can be used to register new metrics with Flink and to create a nested hierarchy based on the group names. See
MetricGroup
for more information for the metrics system.- Specified by:
getMetricGroup
in interfaceDeserializationSchema.InitializationContext
- See Also:
MetricGroup
-
getUserCodeClassLoader
public UserCodeClassLoader getUserCodeClassLoader()
Description copied from interface:DeserializationSchema.InitializationContext
Gets theUserCodeClassLoader
to load classes that are not in system's classpath, but are part of the jar file of a user job.- Specified by:
getUserCodeClassLoader
in interfaceDeserializationSchema.InitializationContext
- See Also:
UserCodeClassLoader
-
-