org.apache.flink.streaming.api.utils

Class PythonTypeUtils.TypeInfoToProtoConverter

java.lang.Object

org.apache.flink.streaming.api.utils.PythonTypeUtils.TypeInfoToProtoConverter

Enclosing class:

PythonTypeUtils

public static class PythonTypeUtils.TypeInfoToProtoConverter
extends Object

Get coder proto according to the given type information.

Constructor Summary

Constructors

Constructor and Description
TypeInfoToProtoConverter()

Method Summary

Modifier and Type	Method and Description
static FlinkFnApi.TypeInfo	toTypeInfoProto(TypeInformation<?> typeInformation, ClassLoader userClassLoader) userClassLoader could be null if no external class loading is needed, e.g.

Methods inherited from class java.lang.Object

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

Constructor Detail

TypeInfoToProtoConverter

public TypeInfoToProtoConverter()

Method Detail

toTypeInfoProto

public static FlinkFnApi.TypeInfo toTypeInfoProto(TypeInformation<?> typeInformation,
                                                  @Nullable
                                                  ClassLoader userClassLoader)

userClassLoader could be null if no external class loading is needed, e.g. load Avro classes.