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