@PublicEvolving public static interface DeserializationSchema.InitializationContext
DeserializationSchema.open(InitializationContext)
method. It can be
used to:
getMetricGroup()
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. |
MetricGroup getMetricGroup()
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.
MetricGroup
UserCodeClassLoader getUserCodeClassLoader()
UserCodeClassLoader
to load classes that are not in system's classpath,
but are part of the jar file of a user job.UserCodeClassLoader
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.