org.apache.flink.streaming.api.utils

Class PythonTypeUtils.FloatDataConverter

java.lang.Object

org.apache.flink.streaming.api.utils.PythonTypeUtils.DataConverter<Float,Double>

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

All Implemented Interfaces:

Serializable

Enclosing class:

PythonTypeUtils

public static final class PythonTypeUtils.FloatDataConverter
extends PythonTypeUtils.DataConverter<Float,Double>

Python Float will be converted to Double in PemJa, so we need FloatDataConverter to convert Java Double to internal Float.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static PythonTypeUtils.FloatDataConverter	INSTANCE

Constructor Summary

Constructors

Constructor and Description
FloatDataConverter()

Method Summary

Modifier and Type	Method and Description
Double	toExternal(Float value)
Float	toInternal(Double 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.FloatDataConverter INSTANCE

Constructor Detail

FloatDataConverter

public FloatDataConverter()

Method Detail

toInternal

public Float toInternal(Double value)

Specified by:

toInternal in class PythonTypeUtils.DataConverter<Float,Double>

toExternal

public Double toExternal(Float value)

Specified by:

toExternal in class PythonTypeUtils.DataConverter<Float,Double>