org.apache.flink.table.gateway.rest.util

Class RowDataLocalTimeZoneConverter

java.lang.Object

org.apache.flink.table.gateway.rest.util.RowDataLocalTimeZoneConverter

public class RowDataLocalTimeZoneConverter
extends Object

Convert LocalZonedTimestampType data in RowData to TimestampData based on the local time zone.

Constructor Summary

Constructors

Constructor and Description
RowDataLocalTimeZoneConverter(List<org.apache.flink.table.types.logical.LogicalType> logicalTypeList, org.apache.flink.configuration.ReadableConfig config)
RowDataLocalTimeZoneConverter(List<org.apache.flink.table.types.logical.LogicalType> logicalTypeList, TimeZone timeZone)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.table.data.RowData	convertTimeZoneRowData(org.apache.flink.table.data.RowData rowData)
boolean	hasTimeZoneData()

Methods inherited from class java.lang.Object

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

Constructor Detail

RowDataLocalTimeZoneConverter

public RowDataLocalTimeZoneConverter(List<org.apache.flink.table.types.logical.LogicalType> logicalTypeList,
                                     org.apache.flink.configuration.ReadableConfig config)

RowDataLocalTimeZoneConverter

public RowDataLocalTimeZoneConverter(List<org.apache.flink.table.types.logical.LogicalType> logicalTypeList,
                                     TimeZone timeZone)

Method Detail

convertTimeZoneRowData

public org.apache.flink.table.data.RowData convertTimeZoneRowData(org.apache.flink.table.data.RowData rowData)

hasTimeZoneData

public boolean hasTimeZoneData()