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.FieldType	getFieldType(TypeInformation typeInformation)
static FlinkFnApi.TypeInfo	toTypeInfoProto(FlinkFnApi.TypeInfo.FieldType fieldType)

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

getFieldType

public static FlinkFnApi.TypeInfo.FieldType getFieldType(TypeInformation typeInformation)

toTypeInfoProto

public static FlinkFnApi.TypeInfo toTypeInfoProto(FlinkFnApi.TypeInfo.FieldType fieldType)