Interface SerializationSchema.InitializationContext
-
- All Known Implementing Classes:
DummyInitializationContext
- Enclosing interface:
- SerializationSchema<T>
@PublicEvolving public static interface SerializationSchema.InitializationContext
A contextual information provided forSerializationSchema.open(InitializationContext)
method. It can be used to:- Register user metrics via
getMetricGroup()
- Access the user code class loader.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description MetricGroup
getMetricGroup()
Returns the metric group for the parallel subtask of the source that runs thisSerializationSchema
.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
MetricGroup getMetricGroup()
Returns the metric group for the parallel subtask of the source that runs thisSerializationSchema
.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 theUserCodeClassLoader
to load classes that are not in system's classpath, but are part of the jar file of a user job.- See Also:
UserCodeClassLoader
-
-