org.apache.flink.api.common.serialization

Class RuntimeContextInitializationContextAdapters

java.lang.Object

org.apache.flink.api.common.serialization.RuntimeContextInitializationContextAdapters

@Internal
public final class RuntimeContextInitializationContextAdapters
extends Object

A set of adapters between RuntimeContext and DeserializationSchema.InitializationContext or SerializationSchema.InitializationContext.

Constructor Summary

Constructors

Constructor and Description
RuntimeContextInitializationContextAdapters()

Method Summary

Modifier and Type	Method and Description
static DeserializationSchema.InitializationContext	deserializationAdapter(RuntimeContext runtimeContext)
static DeserializationSchema.InitializationContext	deserializationAdapter(RuntimeContext runtimeContext, Function<MetricGroup,MetricGroup> mapMetricGroup)
static SerializationSchema.InitializationContext	serializationAdapter(RuntimeContext runtimeContext)
static SerializationSchema.InitializationContext	serializationAdapter(RuntimeContext runtimeContext, Function<MetricGroup,MetricGroup> mapMetricGroup)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RuntimeContextInitializationContextAdapters

public RuntimeContextInitializationContextAdapters()

Method Detail

deserializationAdapter

public static DeserializationSchema.InitializationContext deserializationAdapter(RuntimeContext runtimeContext)

deserializationAdapter

public static DeserializationSchema.InitializationContext deserializationAdapter(RuntimeContext runtimeContext,
                                                                                 Function<MetricGroup,MetricGroup> mapMetricGroup)

serializationAdapter

public static SerializationSchema.InitializationContext serializationAdapter(RuntimeContext runtimeContext)

serializationAdapter

public static SerializationSchema.InitializationContext serializationAdapter(RuntimeContext runtimeContext,
                                                                             Function<MetricGroup,MetricGroup> mapMetricGroup)