[jira] [Created] (FLINK-19685) When use HBase-Connector lookupFunction, 8 hours less to query `DATE`,`TIME`,`TIMESTAMP` data

["CaoZhen (Jira)" <ji...@apache.org>]

CaoZhen created FLINK-19685:
-------------------------------

             Summary: When use HBase-Connector lookupFunction, 8 hours less to query `DATE`,`TIME`,`TIMESTAMP` data 
                 Key: FLINK-19685
                 URL: https://issues.apache.org/jira/browse/FLINK-19685
             Project: Flink
          Issue Type: Bug
          Components: Connectors / HBase
            Reporter: CaoZhen


from the code:

HBaseSerde#createFieldDecoder
{code:java}
case DATE:
case INTERVAL_YEAR_MONTH:
   return Bytes::toInt;
case TIME_WITHOUT_TIME_ZONE:
   ......
   return Bytes::toInt;
case TIMESTAMP_WITHOUT_TIME_ZONE:
case TIMESTAMP_WITH_LOCAL_TIME_ZONE:
   ......
   return createTimestampDecoder();


private static FieldDecoder createTimestampDecoder() {
   return value -> {
      // TODO: support higher precision
      long milliseconds = Bytes.toLong(value);
      return TimestampData.fromEpochMillis(milliseconds);
   };
}
{code}
 

 

 

 

 

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)