You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by dw...@apache.org on 2019/11/07 07:51:09 UTC
[flink] branch master updated (28cf30d -> 0b28e83)

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

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


    from 28cf30d  [FLINK-14608][formats] Remove java stream from JsonRowDeserializationSchema
     add 59339ac  [FLINK-13702][flink-table-planner] Fix NullSerializer & NullAwareMapSerializer snapshotting
     add dcb29bd  [FLINK-13702][flink-table-planner] Fix accumulator type of CollectAggFunction
     add 960ac40  [FLINK-13702][flink-table-planner] Fix digest of GenericRelDataType
     add 0b28e83  [FLINK-13702][table-planner-blink] Fixed BinaryGeneric & BinaryString materialization

No new revisions were added by this update.

Summary of changes:
 flink-table/flink-table-common/pom.xml             |  14 ++
 .../flink/table/dataview/ListViewTypeInfo.java     |   2 +-
 .../flink/table/dataview/MapViewTypeInfo.java      |   2 +-
 .../table/dataview/NullAwareMapSerializer.java     |   2 +-
 ...ot.java => NullAwareMapSerializerSnapshot.java} |  25 ++-
 .../flink/table/dataview/NullSerializer.java       |  17 +-
 .../table/dataview/NullAwareMapSerializerTest.java |  27 ++-
 .../functions/aggfunctions/CollectAggFunction.java |  22 ++
 .../FirstValueWithRetractAggFunction.java          |   6 +-
 .../LastValueWithRetractAggFunction.java           |   4 +-
 .../flink/table/planner/codegen/CodeGenUtils.scala |   5 +-
 .../planner/plan/schema/GenericRelDataType.scala   |   2 +-
 .../planner/codegen/SortCodeGeneratorTest.java     |  16 +-
 .../table/dataformat/AbstractBinaryWriter.java     |  31 +--
 .../apache/flink/table/dataformat/BinaryArray.java |   6 +-
 .../flink/table/dataformat/BinaryFormat.java       |  87 ++------
 .../flink/table/dataformat/BinaryGeneric.java      |  49 ++---
 .../apache/flink/table/dataformat/BinaryMap.java   |  12 +-
 .../apache/flink/table/dataformat/BinaryRow.java   |   8 +-
 .../flink/table/dataformat/BinarySection.java      |  74 +++++++
 .../flink/table/dataformat/BinaryString.java       | 239 ++++++++++++---------
 .../flink/table/dataformat/BinaryStringUtil.java   | 119 +++++-----
 .../flink/table/dataformat/BinaryWriter.java       |   5 +-
 .../table/dataformat/DataFormatConverters.java     |   2 +-
 .../flink/table/dataformat/LazyBinaryFormat.java   |  73 ++++---
 .../apache/flink/table/dataformat/NestedRow.java   |   5 +-
 .../runtime/typeutils/BinaryGenericSerializer.java |  76 +++----
 .../apache/flink/table/dataformat/BaseRowTest.java |  11 +-
 .../flink/table/dataformat/BinaryArrayTest.java    |  10 +-
 .../flink/table/dataformat/BinaryRowTest.java      |  63 ++++--
 .../flink/table/dataformat/BinaryStringTest.java   |  17 +-
 .../flink/table/dataformat/NestedRowTest.java      |  10 +-
 .../runtime/typeutils/BaseArraySerializerTest.java |   2 +-
 .../runtime/typeutils/BaseMapSerializerTest.java   |   2 +-
 .../typeutils/BinaryGenericSerializerTest.java     |  21 +-
 .../flink/table/utils/BinaryGenericAsserter.java   |  78 +++++++
 36 files changed, 691 insertions(+), 453 deletions(-)
 copy flink-table/flink-table-common/src/main/java/org/apache/flink/table/dataview/{MapViewSerializerSnapshot.java => NullAwareMapSerializerSnapshot.java} (61%)
 copy flink-core/src/test/java/org/apache/flink/api/common/typeutils/base/MapSerializerTest.java => flink-table/flink-table-common/src/test/java/org/apache/flink/table/dataview/NullAwareMapSerializerTest.java (77%)
 create mode 100644 flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/BinarySection.java
 create mode 100644 flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/utils/BinaryGenericAsserter.java