org.apache.flink.streaming.api.utils

Class PythonTypeUtils.IntDataConverter

java.lang.Object

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

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

All Implemented Interfaces:

Serializable

Enclosing class:

PythonTypeUtils

public static final class PythonTypeUtils.IntDataConverter
extends PythonTypeUtils.DataConverter<Integer,Long>

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

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static PythonTypeUtils.IntDataConverter	INSTANCE

Constructor Summary

Constructors

Constructor and Description
IntDataConverter()

Method Summary

Modifier and Type	Method and Description
Long	toExternal(Integer value)
Integer	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.IntDataConverter INSTANCE

Constructor Detail

IntDataConverter

public IntDataConverter()

Method Detail

toInternal

public Integer toInternal(Long value)

Specified by:

toInternal in class PythonTypeUtils.DataConverter<Integer,Long>

toExternal

public Long toExternal(Integer value)

Specified by:

toExternal in class PythonTypeUtils.DataConverter<Integer,Long>