Package org.apache.flink.connector.testutils.formats

Class DummyInitializationContext

java.lang.Object

org.apache.flink.connector.testutils.formats.DummyInitializationContext

All Implemented Interfaces:

DeserializationSchema.InitializationContext, SerializationSchema.InitializationContext

public class DummyInitializationContext
extends Object
implements SerializationSchema.InitializationContext, DeserializationSchema.InitializationContext

A dummy context for serialization schemas.

Constructor Summary

Constructors

Constructor	Description
DummyInitializationContext()

Method Summary

Modifier and Type	Method	Description
MetricGroup	getMetricGroup()	Returns the metric group for the parallel subtask of the source that runs this SerializationSchema.
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

DummyInitializationContext

public DummyInitializationContext()

Method Detail

getMetricGroup

public MetricGroup getMetricGroup()

Description copied from interface: SerializationSchema.InitializationContext

Returns the metric group for the parallel subtask of the source that runs this SerializationSchema.

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

Specified by:

getMetricGroup in interface SerializationSchema.InitializationContext

See Also:

MetricGroup

getUserCodeClassLoader

public UserCodeClassLoader getUserCodeClassLoader()

Description copied from interface: SerializationSchema.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

Specified by:

getUserCodeClassLoader in interface SerializationSchema.InitializationContext

See Also:

UserCodeClassLoader