This is an automated email from the ASF dual-hosted git repository.
zakelly pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 73afb6e636c [FLINK-36491][table-common] Remove the deprecated method
in DataStreamSinkProvider (#25564)
add b50a25f7fc4 [FLINK-36120][Runtime] Declarative callbacks for async
state processing
add 5513369d50a [FLINK-36120][Runtime/State] Declaring local variables in
async processing
add 61cabed4da8 [FLINK-36120][Runtime] Declaring basic processing by chain
add 47cdb03494e [FLINK-36120][Runtime] Introduce internal async version of
KeyedProcessFunction
add 4952b58d27b [FLINK-36120][Runtime] Declare context variables without
the ability of serialization
No new revisions were added by this update.
Summary of changes:
.../asyncprocessing/AsyncExecutionController.java | 38 ++--
.../runtime/asyncprocessing/RecordContext.java | 45 ++++-
.../asyncprocessing/declare/ContextVariable.java | 53 +++++
.../asyncprocessing/declare/DeclarationChain.java | 208 +++++++++++++++++++
.../declare/DeclarationContext.java | 119 +++++++++++
.../declare/DeclarationException.java | 27 +++
.../declare/DeclarationManager.java | 101 ++++++++++
.../asyncprocessing/declare/DeclaredVariable.java | 44 +++++
.../asyncprocessing/declare/NamedBiFunction.java | 43 ++++
.../asyncprocessing/declare/NamedCallback.java | 37 ++++
.../asyncprocessing/declare/NamedConsumer.java | 40 ++++
.../asyncprocessing/declare/NamedFunction.java | 42 ++++
.../AbstractAsyncStatefulRichFunction.java | 60 ++++++
.../functions/AsyncStatefulRichFunction.java | 101 ++++++++++
.../AbstractAsyncStateStreamOperator.java | 10 +
.../AbstractAsyncStateStreamOperatorV2.java | 10 +
.../operators/AsyncKeyedProcessOperator.java | 220 +++++++++++++++++++++
.../TimestampedCollectorWithDeclaredVariable.java | 129 ++++++++++++
.../streaming/api/AsyncKeyedProcessFunction.java | 122 ++++++++++++
.../AsyncStateProcessingOperator.java | 4 +
.../asyncprocessing/AbstractStateIteratorTest.java | 3 +
.../AsyncExecutionControllerTest.java | 2 +
.../ContextStateFutureImplTest.java | 2 +-
.../state/v2/AbstractAggregatingStateTest.java | 2 +
.../state/v2/AbstractKeyedStateTestBase.java | 2 +
.../state/v2/AbstractReducingStateTest.java | 2 +
.../runtime/state/v2/StateBackendTestV2Base.java | 6 +
.../InternalTimerServiceAsyncImplTest.java | 2 +
.../state/forst/ForStDBOperationTestBase.java | 2 +-
.../flink/state/forst/ForStStateExecutorTest.java | 4 +-
.../flink/state/forst/ForStStateTestBase.java | 2 +
.../operators/AsyncKeyedProcessOperatorTest.java | 209 ++++++++++++++++++++
32 files changed, 1670 insertions(+), 21 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/declare/ContextVariable.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/declare/DeclarationChain.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/declare/DeclarationContext.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/declare/DeclarationException.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/declare/DeclarationManager.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/declare/DeclaredVariable.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/declare/NamedBiFunction.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/declare/NamedCallback.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/declare/NamedConsumer.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/declare/NamedFunction.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/functions/AbstractAsyncStatefulRichFunction.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/functions/AsyncStatefulRichFunction.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/operators/AsyncKeyedProcessOperator.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/operators/TimestampedCollectorWithDeclaredVariable.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/streaming/api/AsyncKeyedProcessFunction.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/asyncprocessing/operators/AsyncKeyedProcessOperatorTest.java
