Package org.apache.flink.table.data.conversion

Class YearMonthIntervalPeriodConverter

java.lang.Object

org.apache.flink.table.data.conversion.YearMonthIntervalPeriodConverter

All Implemented Interfaces:

Serializable, DataStructureConverter<Integer,java.time.Period>

@Internal
public class YearMonthIntervalPeriodConverter
extends Object
implements DataStructureConverter<Integer,java.time.Period>

Converter for YearMonthIntervalType of Period external type.

See Also:

Serialized Form

Method Summary

Modifier and Type	Method	Description
static YearMonthIntervalPeriodConverter	create(org.apache.flink.table.types.DataType dataType)
static YearMonthIntervalPeriodConverter	create(org.apache.flink.table.types.logical.YearMonthIntervalType intervalType)
java.time.Period	toExternal(Integer internal)	Converts to external data structure.
Integer	toInternal(java.time.Period external)	Converts to internal data structure.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.table.data.conversion.DataStructureConverter

isIdentityConversion, open, toExternalOrNull, toInternalOrNull

Method Detail

toInternal

public Integer toInternal(java.time.Period external)

Description copied from interface: DataStructureConverter

Converts to internal data structure.

Note: Parameter must not be null. Output must not be null.

Specified by:

toInternal in interface DataStructureConverter<Integer,java.time.Period>

toExternal

public java.time.Period toExternal(Integer internal)

Description copied from interface: DataStructureConverter

Converts to external data structure.

Note: Parameter must not be null. Output must not be null.

Specified by:

toExternal in interface DataStructureConverter<Integer,java.time.Period>

create

public static YearMonthIntervalPeriodConverter create(org.apache.flink.table.types.DataType dataType)

create

public static YearMonthIntervalPeriodConverter create(org.apache.flink.table.types.logical.YearMonthIntervalType intervalType)