@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 . |
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
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.