org.apache.flink.api.common.serialization

Interface SerializationSchema.InitializationContext

All Known Implementing Classes:

DummyInitializationContext

Enclosing interface:

SerializationSchema<T>

@PublicEvolving
public static interface SerializationSchema.InitializationContext

A contextual information provided for SerializationSchema.open(InitializationContext) method. It can be used to:

• Register user metrics via getMetricGroup()
• Access the user code class loader.

Method Summary

Modifier and Type	Method and 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.

Method Detail

getMetricGroup

MetricGroup getMetricGroup()

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.

See Also:

MetricGroup

getUserCodeClassLoader

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.

See Also:

UserCodeClassLoader