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)
