org.apache.flink.streaming.api.utils

Class PythonTypeUtils.ByteDataConverter

java.lang.Object

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

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

All Implemented Interfaces:

Serializable

Enclosing class:

PythonTypeUtils

public static final class PythonTypeUtils.ByteDataConverter
extends PythonTypeUtils.DataConverter<Byte,Long>

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

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static PythonTypeUtils.ByteDataConverter	INSTANCE

Constructor Summary

Constructors

Constructor and Description
ByteDataConverter()

Method Summary

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

Constructor Detail

ByteDataConverter

public ByteDataConverter()

Method Detail

toInternal

public Byte toInternal(Long value)

Specified by:

toInternal in class PythonTypeUtils.DataConverter<Byte,Long>

toExternal

public Long toExternal(Byte value)

Specified by:

toExternal in class PythonTypeUtils.DataConverter<Byte,Long>