org.apache.flink.streaming.api.utils

Class PythonTypeUtils.ShortDataConverter

java.lang.Object

org.apache.flink.streaming.api.utils.PythonTypeUtils.DataConverter<Short,Long>

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

All Implemented Interfaces:

Serializable

Enclosing class:

PythonTypeUtils

public static final class PythonTypeUtils.ShortDataConverter
extends PythonTypeUtils.DataConverter<Short,Long>

Python Long will be converted to Long in PemJa, so we need ShortDataConverter to convert Java Long to internal Short.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static PythonTypeUtils.ShortDataConverter	INSTANCE

Constructor Summary

Constructors

Constructor and Description
ShortDataConverter()

Method Summary

Modifier and Type	Method and Description
Long	toExternal(Short value)
Short	toInternal(Long value)

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static final PythonTypeUtils.ShortDataConverter INSTANCE

Constructor Detail

ShortDataConverter

public ShortDataConverter()

Method Detail

toInternal

public Short toInternal(Long value)

Specified by:

toInternal in class PythonTypeUtils.DataConverter<Short,Long>

toExternal

public Long toExternal(Short value)

Specified by:

toExternal in class PythonTypeUtils.DataConverter<Short,Long>