This is an automated email from the ASF dual-hosted git repository.
zakelly pushed a change to branch release-2.0
in repository https://gitbox.apache.org/repos/asf/flink.git
from 3f8aadc1e01 [hotfix] Remove inappropriate annotation in
`flink-statebackend-forst` (#26124)
new f335f1f7b7c [hotfix] Add constructors for state v2 descriptors that
accept type class
new bfdc6db0955 [FLINK-37276] Add missing state v2 access interfaces in
`RuntimeContext`
The 2 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:
.../flink/api/common/functions/RuntimeContext.java | 90 ++++++++++++++++++++++
.../functions/util/AbstractRuntimeUDFContext.java | 37 +++++++++
.../state/v2/AggregatingStateDescriptor.java | 21 ++++-
.../api/common/state/v2/ListStateDescriptor.java | 13 ++++
.../api/common/state/v2/MapStateDescriptor.java | 16 ++++
.../common/state/v2/ReducingStateDescriptor.java | 17 ++++
.../flink/api/common/state/v2/StateDescriptor.java | 15 ++++
.../common/state/v2/StateSerializerReference.java | 17 ++++
.../api/common/state/v2/ValueStateDescriptor.java | 13 ++++
.../flink/cep/operator/CepRuntimeContext.java | 32 ++++++++
.../flink/cep/operator/CepRuntimeContextTest.java | 45 +++++++++++
.../state/api/runtime/SavepointRuntimeContext.java | 32 ++++++++
.../api/operators/StreamingRuntimeContext.java | 10 +++
.../api/functions/async/RichAsyncFunction.java | 38 +++++++++
.../api/functions/async/RichAsyncFunctionTest.java | 73 ++++++++++++++++++
.../async/AsyncStateGroupAggFunction.java | 3 +-
.../AsyncStateDeduplicateFunctionBase.java | 3 +-
.../rank/async/AbstractAsyncStateTopNFunction.java | 4 +-
.../async/AsyncStateAppendOnlyTopNFunction.java | 3 +-
.../rank/async/AsyncStateFastTop1Function.java | 4 +-
20 files changed, 472 insertions(+), 14 deletions(-)
