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 fb5fd483f91 [FLINK-35570][Checkpoint] Consider
PlaceholderStreamStateHandle in file merging
new f91730dccb6 [FLINK-34977][API] Introduce TypeDescriptor and TypeUtils
new c6c7c99bdec [FLINK-34977][API] Introduce Type Descriptors
new f0c3b986137 [FLINK-34977][API] Move Reduce and Aggregate functions to
flink-core-api
new 2998ef1aeb2 [FLINK-34977][API] Support State Declarations
new 3c77ccca550 [FLINK-34977][API] Add useStates to the ProcessFunction
new a3ef9b72db9 [FLINK-34977][API] Move State interfaces to flink-core-api
new 9a47e375d97 [FLINK-34977][API] Introduce State Access on DataStream
API V2
new 2a6ee6488cb [FLINK-34977][API] Support compile-time checks for invalid
states
new 03b3d26d8fe [FLINK-34977][test] Introduce DataStream V2 IT Tests
The 9 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:
.../api/common/functions/AggregateFunction.java | 0
.../flink/api/common/functions/ReduceFunction.java | 0
.../flink/api/common/state/AggregatingState.java | 0
.../common/state/AggregatingStateDeclaration.java | 21 +-
.../flink/api/common/state/AppendingState.java | 0
.../flink/api/common/state/BroadcastState.java | 0
.../common/state/BroadcastStateDeclaration.java | 22 +-
.../state/IllegalRedistributionModeException.java | 21 +-
.../apache/flink/api/common/state/ListState.java | 0
.../api/common/state/ListStateDeclaration.java | 54 +++
.../apache/flink/api/common/state/MapState.java | 0
.../api/common/state/MapStateDeclaration.java | 22 +-
.../flink/api/common/state/MergingState.java | 0
.../api/common/state/ReadOnlyBroadcastState.java | 0
.../flink/api/common/state/ReducingState.java | 0
.../api/common/state/ReducingStateDeclaration.java | 21 +-
.../org/apache/flink/api/common/state/State.java | 0
.../flink/api/common/state/StateDeclaration.java | 67 ++++
.../flink/api/common/state/StateDeclarations.java | 379 +++++++++++++++++++++
.../apache/flink/api/common/state/ValueState.java | 4 +-
.../api/common/state/ValueStateDeclaration.java | 19 +-
.../flink/api/common/typeinfo/TypeDescriptor.java | 21 +-
.../flink/api/common/typeinfo/TypeDescriptors.java | 152 +++++++++
.../flink/api/common/typeinfo/utils/TypeUtils.java | 125 +++++++
.../descriptor/BasicTypeDescriptorImpl.java | 54 +++
.../descriptor/ListTypeDescriptorImpl.java | 64 ++++
.../typeinfo/descriptor/MapTypeDescriptorImpl.java | 69 ++++
.../descriptor/ValueTypeDescriptorImpl.java | 55 +++
.../state/AggregatingStateDeclarationTest.java | 85 +++++
.../api/common/state/ListStateDeclarationTest.java | 63 ++++
.../api/common/state/MapStateDeclarationTest.java | 71 ++++
.../common/state/ReducingStateDeclarationTest.java | 64 ++++
.../common/state/ValueStateDeclarationTest.java | 58 ++++
.../flink/datastream/api/context/StateManager.java | 67 ++++
.../datastream/api/function/ProcessFunction.java | 14 +
.../impl/context/DefaultPartitionedContext.java | 10 +-
.../impl/context/DefaultStateManager.java | 110 +++++-
.../datastream/impl/operators/ProcessOperator.java | 7 +-
.../TwoInputBroadcastProcessOperator.java | 7 +-
.../TwoInputNonBroadcastProcessOperator.java | 10 +-
.../impl/operators/TwoOutputProcessOperator.java | 9 +-
.../impl/stream/BroadcastStreamImpl.java | 13 +
.../datastream/impl/stream/GlobalStreamImpl.java | 24 ++
.../impl/stream/KeyedPartitionStreamImpl.java | 41 +++
.../impl/stream/NonKeyedPartitionStreamImpl.java | 32 ++
.../flink/datastream/impl/utils/StreamUtils.java | 18 +
.../impl/common/BasicTypeDescriptorTest.java | 51 +++
.../impl/common/ListTypeDescriptorTest.java | 52 +++
.../impl/common/MapTypeDescriptorTest.java | 72 ++++
.../datastream/impl/common/TypeUtilsTest.java | 70 ++++
.../impl/common/ValueTypeDescriptorTest.java | 91 +++++
.../context/DefaultNonPartitionedContextTest.java | 10 +-
.../impl/context/DefaultStateManagerTest.java | 219 +++++++++++-
.../DefaultTwoOutputNonPartitionedContextTest.java | 10 +-
.../operators/MockFreqCountProcessFunction.java | 61 ++++
.../MockGlobalDecuplicateCountProcessFunction.java | 67 ++++
.../MockGlobalListAppenderProcessFunction.java | 78 +++++
.../operators/MockListAppenderProcessFunction.java | 77 +++++
.../operators/MockMultiplierProcessFunction.java | 59 ++++
.../MockRecudingMultiplierProcessFunction.java | 68 ++++
.../operators/MockSumAggregateProcessFunction.java | 83 +++++
.../impl/stream/BroadcastStreamImplTest.java | 58 ++++
.../impl/stream/GlobalStreamImplTest.java | 79 +++++
.../impl/stream/KeyedPartitionStreamImplTest.java | 85 +++++
.../stream/NonKeyedPartitionStreamImplTest.java | 110 ++++++
.../datastream/impl/stream/StreamTestUtils.java | 67 ++++
.../api/datastream/StatefulDataStreamV2ITCase.java | 319 +++++++++++++++++
pom.xml | 12 +
68 files changed, 3581 insertions(+), 90 deletions(-)
rename {flink-core =>
flink-core-api}/src/main/java/org/apache/flink/api/common/functions/AggregateFunction.java
(100%)
rename {flink-core =>
flink-core-api}/src/main/java/org/apache/flink/api/common/functions/ReduceFunction.java
(100%)
rename {flink-core =>
flink-core-api}/src/main/java/org/apache/flink/api/common/state/AggregatingState.java
(100%)
copy
flink-datastream-api/src/main/java/org/apache/flink/datastream/api/context/StateManager.java
=>
flink-core-api/src/main/java/org/apache/flink/api/common/state/AggregatingStateDeclaration.java
(62%)
rename {flink-core =>
flink-core-api}/src/main/java/org/apache/flink/api/common/state/AppendingState.java
(100%)
rename {flink-core =>
flink-core-api}/src/main/java/org/apache/flink/api/common/state/BroadcastState.java
(100%)
copy
flink-core/src/main/java/org/apache/flink/api/common/state/MergingState.java =>
flink-core-api/src/main/java/org/apache/flink/api/common/state/BroadcastStateDeclaration.java
(62%)
copy
flink-core/src/main/java/org/apache/flink/api/common/state/MergingState.java =>
flink-core-api/src/main/java/org/apache/flink/api/common/state/IllegalRedistributionModeException.java
(62%)
rename {flink-core =>
flink-core-api}/src/main/java/org/apache/flink/api/common/state/ListState.java
(100%)
create mode 100644
flink-core-api/src/main/java/org/apache/flink/api/common/state/ListStateDeclaration.java
rename {flink-core =>
flink-core-api}/src/main/java/org/apache/flink/api/common/state/MapState.java
(100%)
copy
flink-core/src/main/java/org/apache/flink/api/common/state/MergingState.java =>
flink-core-api/src/main/java/org/apache/flink/api/common/state/MapStateDeclaration.java
(62%)
copy {flink-core =>
flink-core-api}/src/main/java/org/apache/flink/api/common/state/MergingState.java
(100%)
rename {flink-core =>
flink-core-api}/src/main/java/org/apache/flink/api/common/state/ReadOnlyBroadcastState.java
(100%)
rename {flink-core =>
flink-core-api}/src/main/java/org/apache/flink/api/common/state/ReducingState.java
(100%)
copy
flink-datastream-api/src/main/java/org/apache/flink/datastream/api/context/StateManager.java
=>
flink-core-api/src/main/java/org/apache/flink/api/common/state/ReducingStateDeclaration.java
(62%)
rename {flink-core =>
flink-core-api}/src/main/java/org/apache/flink/api/common/state/State.java
(100%)
create mode 100644
flink-core-api/src/main/java/org/apache/flink/api/common/state/StateDeclaration.java
create mode 100644
flink-core-api/src/main/java/org/apache/flink/api/common/state/StateDeclarations.java
rename {flink-core =>
flink-core-api}/src/main/java/org/apache/flink/api/common/state/ValueState.java
(95%)
rename
flink-core/src/main/java/org/apache/flink/api/common/state/MergingState.java =>
flink-core-api/src/main/java/org/apache/flink/api/common/state/ValueStateDeclaration.java
(62%)
copy
flink-datastream-api/src/main/java/org/apache/flink/datastream/api/context/StateManager.java
=>
flink-core-api/src/main/java/org/apache/flink/api/common/typeinfo/TypeDescriptor.java
(64%)
create mode 100644
flink-core-api/src/main/java/org/apache/flink/api/common/typeinfo/TypeDescriptors.java
create mode 100644
flink-core-api/src/main/java/org/apache/flink/api/common/typeinfo/utils/TypeUtils.java
create mode 100644
flink-core/src/main/java/org/apache/flink/api/common/typeinfo/descriptor/BasicTypeDescriptorImpl.java
create mode 100644
flink-core/src/main/java/org/apache/flink/api/common/typeinfo/descriptor/ListTypeDescriptorImpl.java
create mode 100644
flink-core/src/main/java/org/apache/flink/api/common/typeinfo/descriptor/MapTypeDescriptorImpl.java
create mode 100644
flink-core/src/main/java/org/apache/flink/api/common/typeinfo/descriptor/ValueTypeDescriptorImpl.java
create mode 100644
flink-core/src/test/java/org/apache/flink/api/common/state/AggregatingStateDeclarationTest.java
create mode 100644
flink-core/src/test/java/org/apache/flink/api/common/state/ListStateDeclarationTest.java
create mode 100644
flink-core/src/test/java/org/apache/flink/api/common/state/MapStateDeclarationTest.java
create mode 100644
flink-core/src/test/java/org/apache/flink/api/common/state/ReducingStateDeclarationTest.java
create mode 100644
flink-core/src/test/java/org/apache/flink/api/common/state/ValueStateDeclarationTest.java
create mode 100644
flink-datastream/src/test/java/org/apache/flink/datastream/impl/common/BasicTypeDescriptorTest.java
create mode 100644
flink-datastream/src/test/java/org/apache/flink/datastream/impl/common/ListTypeDescriptorTest.java
create mode 100644
flink-datastream/src/test/java/org/apache/flink/datastream/impl/common/MapTypeDescriptorTest.java
create mode 100644
flink-datastream/src/test/java/org/apache/flink/datastream/impl/common/TypeUtilsTest.java
create mode 100644
flink-datastream/src/test/java/org/apache/flink/datastream/impl/common/ValueTypeDescriptorTest.java
create mode 100644
flink-datastream/src/test/java/org/apache/flink/datastream/impl/operators/MockFreqCountProcessFunction.java
create mode 100644
flink-datastream/src/test/java/org/apache/flink/datastream/impl/operators/MockGlobalDecuplicateCountProcessFunction.java
create mode 100644
flink-datastream/src/test/java/org/apache/flink/datastream/impl/operators/MockGlobalListAppenderProcessFunction.java
create mode 100644
flink-datastream/src/test/java/org/apache/flink/datastream/impl/operators/MockListAppenderProcessFunction.java
create mode 100644
flink-datastream/src/test/java/org/apache/flink/datastream/impl/operators/MockMultiplierProcessFunction.java
create mode 100644
flink-datastream/src/test/java/org/apache/flink/datastream/impl/operators/MockRecudingMultiplierProcessFunction.java
create mode 100644
flink-datastream/src/test/java/org/apache/flink/datastream/impl/operators/MockSumAggregateProcessFunction.java
create mode 100644
flink-tests/src/test/java/org/apache/flink/test/streaming/api/datastream/StatefulDataStreamV2ITCase.java
