@Internal public class PulsarDeserializationSchemaInitializationContext extends Object implements DeserializationSchema.InitializationContext
SourceReaderContext
into a DeserializationSchema.InitializationContext
, we would use a pulsar named metric group for this
content.Constructor and Description |
---|
PulsarDeserializationSchemaInitializationContext(SourceReaderContext readerContext) |
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. |
public PulsarDeserializationSchemaInitializationContext(SourceReaderContext readerContext)
public MetricGroup getMetricGroup()
DeserializationSchema.InitializationContext
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.
getMetricGroup
in interface DeserializationSchema.InitializationContext
MetricGroup
public UserCodeClassLoader getUserCodeClassLoader()
DeserializationSchema.InitializationContext
UserCodeClassLoader
to load classes that are not in system's classpath,
but are part of the jar file of a user job.getUserCodeClassLoader
in interface DeserializationSchema.InitializationContext
UserCodeClassLoader
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.