Interface SerializationSchema.InitializationContext
-
- Enclosing interface:
- SerializationSchema<T>
@PublicEvolving public static interface SerializationSchema.InitializationContextA 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 org.apache.flink.metrics.MetricGroupgetMetricGroup()Returns the metric group for the parallel subtask of the source that runs thisSerializationSchema.UserCodeClassLoadergetUserCodeClassLoader()Gets theUserCodeClassLoaderto load classes that are not in system's classpath, but are part of the jar file of a user job.
-
-
-
Method Detail
-
getMetricGroup
org.apache.flink.metrics.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
MetricGroupfor more information for the metrics system.- See Also:
MetricGroup
-
getUserCodeClassLoader
UserCodeClassLoader getUserCodeClassLoader()
Gets theUserCodeClassLoaderto load classes that are not in system's classpath, but are part of the jar file of a user job.- See Also:
UserCodeClassLoader
-
-