[flink] branch master updated (7cd3538 -> c31fdc6)

[tw...@apache.org]

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

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


    from 7cd3538  [FLINK-18831][docs][python] Improve the documentation about the operations in Python Table API
     add 7175859  [hotfix][table-common] Fix invalid conversion class in data type transformer
     add f5bf213  [hotfix][table-runtime-blink] Return mutable instances for List converter
     add 39f11f9  [hotfix][table-planner-blink] Remove PlannerTypeUtils.getArity
     add 199c632  [hotfix][table-planner-blink] Reuse data structure converters whenever possible
     add c55665e  [FLINK-15803][table] Replace type information with serializer in StateDataViewStore
     add 14e5fd2  [hotfix][core] Allow null instances in serializer tests
     add ae3ccb9  [FLINK-15803][table-runtime-blink] Add an external serializer that can handle all data types
     add e00f7e9  [FLINK-15803][table-common] Update DataView classes to the new type system
     add 25b18fd  [FLINK-15803][table-common] Integrate data views into data type extractor
     add f9843ad  [hotfix][table-common] Ensure valid internal class hierarchy for data types
     add c31fdc6  [FLINK-15803][table] Support DataViews in FLIP-65 aggregate functions

No new revisions were added by this update.

Summary of changes:
 .../api/common/typeutils/SerializerTestBase.java   |  15 +-
 .../kryo/KryoGenericTypeSerializerTest.java        |  11 +-
 .../apache/flink/table/api/dataview/DataView.java  |  14 +-
 .../apache/flink/table/api/dataview/ListView.java  | 133 +++++++----
 .../apache/flink/table/api/dataview/MapView.java   | 153 ++++++++-----
 .../flink/table/dataview/ListViewSerializer.java   |  11 +-
 .../table/dataview/ListViewSerializerSnapshot.java |   1 +
 .../flink/table/dataview/ListViewTypeInfo.java     |   1 +
 .../table/dataview/ListViewTypeInfoFactory.java    |   1 +
 .../flink/table/dataview/MapViewSerializer.java    |  11 +-
 .../table/dataview/MapViewSerializerSnapshot.java  |   1 +
 .../flink/table/dataview/MapViewTypeInfo.java      |   1 +
 .../table/dataview/MapViewTypeInfoFactory.java     |   1 +
 .../table/dataview/NullAwareMapSerializer.java     |   1 +
 .../dataview/NullAwareMapSerializerSnapshot.java   |   1 +
 .../flink/table/dataview/NullSerializer.java       |   9 +-
 .../flink/table/functions/AggregateFunction.java   |   5 +
 .../table/functions/TableAggregateFunction.java    |   5 +
 .../flink/table/types/CollectionDataType.java      |  26 ++-
 .../apache/flink/table/types/FieldsDataType.java   |  20 +-
 .../apache/flink/table/types/KeyValueDataType.java |  18 +-
 .../table/types/extraction/DataTypeExtractor.java  |  50 +++-
 .../types/logical/LegacyTypeInformationType.java   |   6 +-
 .../flink/table/types/utils/DataTypeUtils.java     |  19 +-
 .../org/apache/flink/table/types/DataTypeTest.java |  28 +++
 .../types/extraction/DataTypeExtractorTest.java    |  84 ++++++-
 .../types/inference/TypeTransformationsTest.java   |   5 +-
 .../ListAggWithRetractAggFunction.java             |  27 +++
 .../table/planner/typeutils/DataViewUtils.java     | 254 +++++++++++++++++++++
 .../flink/table/planner/codegen/CodeGenUtils.scala |   7 +-
 .../planner/codegen/CodeGeneratorContext.scala     |  69 ++++--
 .../table/planner/codegen/ExpressionReducer.scala  |   9 +-
 .../codegen/agg/AggsHandlerCodeGenerator.scala     |  68 ++++--
 .../planner/codegen/agg/ImperativeAggCodeGen.scala |  13 +-
 .../table/planner/dataview/DataViewSpec.scala      |  48 ----
 .../table/planner/plan/utils/AggregateUtil.scala   |  46 +++-
 .../table/planner/plan/utils/aggregation.scala     |   2 +-
 .../LegacyDataViewUtils.scala}                     |  22 +-
 .../runtime/utils/JavaUserDefinedAggFunctions.java |  18 +-
 .../table/planner/codegen/agg/AggTestBase.scala    |   7 +-
 .../runtime/stream/sql/AggregateITCase.scala       |   2 +-
 .../runtime/stream/table/AggregateITCase.scala     |   9 +-
 .../aggfunctions/DistinctAccumulator.scala         |   2 +-
 .../table/data/conversion/ArrayListConverter.java  |   3 +-
 .../runtime/dataview/PerKeyStateDataViewStore.java |  42 ++--
 .../dataview/PerWindowStateDataViewStore.java      |  54 +++--
 .../table/runtime/dataview/StateDataView.java      |   2 +
 .../table/runtime/dataview/StateDataViewStore.java |  34 +--
 .../table/runtime/dataview/StateListView.java      |  56 +++--
 .../flink/table/runtime/dataview/StateMapView.java | 197 ++++++++--------
 .../table/runtime/types/PlannerTypeUtils.java      |  11 -
 .../runtime/typeutils/ExternalSerializer.java      | 226 ++++++++++++++++++
 .../runtime/typeutils/ExternalSerializerTest.java  | 186 +++++++++++++++
 53 files changed, 1598 insertions(+), 447 deletions(-)
 create mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/typeutils/DataViewUtils.java
 delete mode 100644 flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/dataview/DataViewSpec.scala
 rename flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/{dataview/DataViewUtils.scala => typeutils/LegacyDataViewUtils.scala} (91%)
 create mode 100644 flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ExternalSerializer.java
 create mode 100644 flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/typeutils/ExternalSerializerTest.java