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/19 12:14:54 UTC
[flink] branch master updated (7aafb24 -> 974f4da)
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 7aafb24 [FLINK-14786][documentation] Regenerated documentation for ExecutionOptions & PipelineOptions
add 974f4da [FLINK-14806][table-runtime-blink] Add get and set interface for SqlTimestamp to BaseRow and VectorizedColumnBatch
No new revisions were added by this update.
Summary of changes:
.../table/dataformat/AbstractBinaryWriter.java | 22 ++++
.../apache/flink/table/dataformat/BinaryArray.java | 40 +++++++
.../apache/flink/table/dataformat/BinaryRow.java | 39 +++++++
.../flink/table/dataformat/BinaryWriter.java | 2 +
.../apache/flink/table/dataformat/ColumnarRow.java | 10 ++
.../flink/table/dataformat/GenericArray.java | 10 ++
.../apache/flink/table/dataformat/JoinedRow.java | 18 ++++
.../apache/flink/table/dataformat/NestedRow.java | 38 +++++++
.../flink/table/dataformat/ObjectArrayRow.java | 10 ++
.../flink/table/dataformat/SqlTimestamp.java | 18 ++++
.../flink/table/dataformat/TypeGetterSetters.java | 15 +++
.../flink/table/dataformat/UpdatableRow.java | 10 ++
.../dataformat/vector/TimestampColumnVector.java | 10 +-
.../dataformat/vector/VectorizedColumnBatch.java | 5 +
.../apache/flink/table/dataformat/BaseRowTest.java | 33 ++++--
.../flink/table/dataformat/BinaryArrayTest.java | 39 +++++++
.../flink/table/dataformat/BinaryRowTest.java | 35 ++++++
.../vector/VectorizedColumnBatchTest.java | 120 ++++++++++++++++++++-
18 files changed, 462 insertions(+), 12 deletions(-)
copy flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/HiveShimV122.java => flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/vector/TimestampColumnVector.java (76%)