org.apache.flink.connector.testutils.source.deserialization

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 of DeserializationSchema.InitializationContext for test.

Constructor Summary

Constructors

Constructor and Description
TestingDeserializationContext()

Method Summary

Modifier and Type	Method and Description
MetricGroup	getMetricGroup() Returns the metric group for the parallel subtask of the source that runs this DeserializationSchema.
UserCodeClassLoader	getUserCodeClassLoader() Gets the UserCodeClassLoader to load classes that are not in system's classpath, but are part of the jar file of a user job.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TestingDeserializationContext

public TestingDeserializationContext()

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 this DeserializationSchema.

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 interface DeserializationSchema.InitializationContext

See Also:

MetricGroup

getUserCodeClassLoader

public UserCodeClassLoader getUserCodeClassLoader()

Description copied from interface: DeserializationSchema.InitializationContext

Gets the UserCodeClassLoader 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 interface DeserializationSchema.InitializationContext

See Also:

UserCodeClassLoader