[flink] branch master updated (dfd79bc -> 4a509fc)

[lz...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from dfd79bc  [FLINK-16370][build] Only bundle javax as Java11-exclusive dependency
     add 4a509fc  [FLINK-16359][table-runtime] Introduce WritableVectors for abstract writing (#11275)

No new revisions were added by this update.

Summary of changes:
 .../orc/nohive/vector/AbstractOrcNoHiveVector.java |   5 -
 .../flink/orc/vector/AbstractOrcColumnVector.java  |   5 -
 .../arrow/vectors/ArrowBigIntColumnVector.java     |   5 -
 .../arrow/vectors/ArrowIntColumnVector.java        |   5 -
 .../arrow/vectors/ArrowSmallIntColumnVector.java   |   5 -
 .../arrow/vectors/ArrowTinyIntColumnVector.java    |   5 -
 .../table/dataformat/vector/BytesColumnVector.java |   5 +-
 .../table/dataformat/vector/ColumnVector.java      |   6 -
 .../flink/table/dataformat/vector/Dictionary.java  |   4 +
 .../dataformat/vector/VectorizedColumnBatch.java   |  10 -
 .../dataformat/vector/heap/AbstractHeapVector.java |  43 ++-
 .../dataformat/vector/heap/HeapBooleanVector.java  |  16 +-
 .../dataformat/vector/heap/HeapByteVector.java     |  16 +-
 .../dataformat/vector/heap/HeapBytesVector.java    |  41 +--
 .../dataformat/vector/heap/HeapDoubleVector.java   |  37 +-
 .../dataformat/vector/heap/HeapFloatVector.java    |  37 +-
 .../dataformat/vector/heap/HeapIntVector.java      |  47 ++-
 .../dataformat/vector/heap/HeapLongVector.java     |  35 +-
 .../dataformat/vector/heap/HeapShortVector.java    |  16 +-
 .../vector/heap/HeapTimestampVector.java           |  64 ++++
 .../AbstractWritableVector.java}                   |  20 +-
 .../WritableBooleanVector.java}                    |  17 +-
 .../WritableByteVector.java}                       |  17 +-
 .../WritableBytesVector.java}                      |  18 +-
 .../vector/writable/WritableColumnVector.java      |  71 ++++
 .../WritableDoubleVector.java}                     |  39 +-
 .../WritableFloatVector.java}                      |  38 +-
 .../vector/writable/WritableIntVector.java         |  57 +++
 .../WritableLongVector.java}                       |  37 +-
 .../WritableShortVector.java}                      |  17 +-
 .../WritableTimestampVector.java}                  |  18 +-
 .../table/dataformat/vector/ColumnVectorTest.java  | 406 +++++++++++++++++++++
 .../vector/VectorizedColumnBatchTest.java          |  60 +--
 33 files changed, 971 insertions(+), 251 deletions(-)
 create mode 100644 flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/vector/heap/HeapTimestampVector.java
 rename flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/vector/{AbstractColumnVector.java => writable/AbstractWritableVector.java} (69%)
 copy flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/vector/{ColumnVector.java => writable/WritableBooleanVector.java} (65%)
 copy flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/vector/{ColumnVector.java => writable/WritableByteVector.java} (66%)
 copy flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/vector/{ColumnVector.java => writable/WritableBytesVector.java} (60%)
 create mode 100644 flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/vector/writable/WritableColumnVector.java
 copy flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/vector/{heap/HeapDoubleVector.java => writable/WritableDoubleVector.java} (52%)
 copy flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/vector/{heap/HeapFloatVector.java => writable/WritableFloatVector.java} (55%)
 create mode 100644 flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/vector/writable/WritableIntVector.java
 copy flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/vector/{heap/HeapLongVector.java => writable/WritableLongVector.java} (56%)
 copy flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/vector/{ColumnVector.java => writable/WritableShortVector.java} (66%)
 copy flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/vector/{ColumnVector.java => writable/WritableTimestampVector.java} (60%)
 create mode 100644 flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/dataformat/vector/ColumnVectorTest.java