You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ku...@apache.org on 2019/11/04 10:01:07 UTC
[flink] branch master updated (7ffe265 -> 845fb95)
This is an automated email from the ASF dual-hosted git repository.
kurt pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 7ffe265 [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. (#9993)
add 845fb95 [FLINK-14080][table-planner-blink] Introduce SqlTimestamp as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE
No new revisions were added by this update.
Summary of changes:
.../flink/table/dataformat/SqlTimestamp.java | 187 ++++++++++++++++++++
.../runtime/typeutils/SqlTimestampSerializer.java | 189 +++++++++++++++++++++
...ringTypeInfo.java => SqlTimestampTypeInfo.java} | 39 +++--
.../flink/table/dataformat/SqlTimestampTest.java | 97 +++++++++++
.../runtime/typeutils/InternalTypeInfoTest.java | 6 +-
.../typeutils}/SqlTimestampSerializerTest.java | 53 +++---
6 files changed, 538 insertions(+), 33 deletions(-)
create mode 100644 flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/SqlTimestamp.java
create mode 100644 flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/SqlTimestampSerializer.java
copy flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/{BinaryStringTypeInfo.java => SqlTimestampTypeInfo.java} (63%)
create mode 100644 flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/dataformat/SqlTimestampTest.java
copy {flink-core/src/test/java/org/apache/flink/api/common/typeutils/base => flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/typeutils}/SqlTimestampSerializerTest.java (51%)