Class RowDataLocalTimeZoneConverter


  • public class RowDataLocalTimeZoneConverter
    extends Object
    Convert LocalZonedTimestampType data in RowData to TimestampData based on the local time zone.
    • 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()