This is an automated email from the ASF dual-hosted git repository.
guoweijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 4a6f84be0b2 [FLINK-37101] Remove legacy internal methods for changing
serializer behavior in SerializerConfig
new 24b661f782e [FLINK-34123][core] Introduce built-in serialization
support for Map, List, and Collection
new aaa88d4e6b3 [FLINK-34123][docs][type] Add doc for built-in
serialization support for Map, List, and Collection
new f46bb434404 [FLINK-35068][core] Introduce built-in serialization
support for java.util.Set
new 7588a4dcda5 [FLINK-35555][core] Introduce
Nullable{Map/List/Set}TypeInfo for collection type serialization with null
value support
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../serialization/types_serialization.md | 26 ++-
.../apache/flink/api/common/typeinfo/Types.java | 19 +++
.../api/common/typeutils/base/SetSerializer.java | 181 +++++++++++++++++++++
.../typeutils/base/SetSerializerSnapshot.java | 59 +++++++
.../flink/api/java/typeutils/ListTypeInfo.java | 2 +-
.../api/java/typeutils/NullableListTypeInfo.java | 60 +++++++
.../api/java/typeutils/NullableMapTypeInfo.java | 63 +++++++
.../api/java/typeutils/NullableSetTypeInfo.java | 58 +++++++
.../{ListTypeInfo.java => SetTypeInfo.java} | 40 ++---
.../flink/api/java/typeutils/TypeExtractor.java | 34 ++++
.../typeutils/base/NullableListSerializerTest.java | 78 +++++++++
.../typeutils/base/NullableMapSerializerTest.java | 80 +++++++++
.../typeutils/base/NullableSetSerializerTest.java | 78 +++++++++
.../common/typeutils/base/SetSerializerTest.java | 86 ++++++++++
.../java/typeutils/NullableListTypeInfoTest.java | 35 ++++
.../java/typeutils/NullableMapTypeInfoTest.java | 35 ++++
.../java/typeutils/NullableSetTypeInfoTest.java | 35 ++++
.../api/java/typeutils/PojoTypeExtractionTest.java | 3 +-
.../flink/api/java/typeutils/SetTypeInfoTest.java | 35 ++++
.../api/java/typeutils/TypeExtractorTest.java | 97 ++++++++++-
.../org/apache/flink/types/PojoTestUtilsTest.java | 2 +-
.../TypeSerializerTestCoverageTest.java | 4 +-
22 files changed, 1076 insertions(+), 34 deletions(-)
create mode 100644
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/SetSerializer.java
create mode 100644
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/SetSerializerSnapshot.java
create mode 100644
flink-core/src/main/java/org/apache/flink/api/java/typeutils/NullableListTypeInfo.java
create mode 100644
flink-core/src/main/java/org/apache/flink/api/java/typeutils/NullableMapTypeInfo.java
create mode 100644
flink-core/src/main/java/org/apache/flink/api/java/typeutils/NullableSetTypeInfo.java
copy
flink-core/src/main/java/org/apache/flink/api/java/typeutils/{ListTypeInfo.java
=> SetTypeInfo.java} (71%)
create mode 100644
flink-core/src/test/java/org/apache/flink/api/common/typeutils/base/NullableListSerializerTest.java
create mode 100644
flink-core/src/test/java/org/apache/flink/api/common/typeutils/base/NullableMapSerializerTest.java
create mode 100644
flink-core/src/test/java/org/apache/flink/api/common/typeutils/base/NullableSetSerializerTest.java
create mode 100644
flink-core/src/test/java/org/apache/flink/api/common/typeutils/base/SetSerializerTest.java
create mode 100644
flink-core/src/test/java/org/apache/flink/api/java/typeutils/NullableListTypeInfoTest.java
create mode 100644
flink-core/src/test/java/org/apache/flink/api/java/typeutils/NullableMapTypeInfoTest.java
create mode 100644
flink-core/src/test/java/org/apache/flink/api/java/typeutils/NullableSetTypeInfoTest.java
create mode 100644
flink-core/src/test/java/org/apache/flink/api/java/typeutils/SetTypeInfoTest.java
