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
