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 105720fc5cb [FLINK-36761][docs] Add document about how to use SQL
Gateway and SQL Client to deploy script (#25784)
add d63a7a44912 [hotfix][state] Fix the wrong type cast in ForStMapState
add 250f0db7716 [FLINK-37003][State] Allow exception in the signature of
StateIterator
add 5df3e4a8abb [FLINK-37003][DS] Implement async state version of
Datastream Interval join
No new revisions were added by this update.
Summary of changes:
.../flink/api/common/state/v2/StateIterator.java | 9 +-
.../asyncprocessing/AbstractStateIterator.java | 32 +-
.../asyncprocessing/declare/ContextVariable.java | 1 +
.../AbstractAsyncStateStreamOperator.java | 14 +-
.../AbstractAsyncStateStreamOperatorV2.java | 17 +-
.../AbstractAsyncStateUdfStreamOperator.java | 4 +
.../operators/AsyncIntervalJoinOperator.java} | 370 +++++++--------------
.../operators/AsyncKeyedProcessOperator.java | 3 -
.../state/v2/adaptor/CompleteStateIterator.java | 37 ++-
.../flink/runtime/state/v2/ttl/TtlListState.java | 12 +-
.../flink/runtime/state/v2/ttl/TtlMapState.java | 33 +-
.../streaming/api/datastream/KeyedStream.java | 81 +++--
.../api/operators/co/IntervalJoinOperator.java | 1 -
.../operators/AsyncIntervalJoinOperatorTest.java} | 71 ++--
...ncKeyedMultiInputStreamOperatorTestHarness.java | 40 ++-
...syncKeyedOneInputStreamOperatorTestHarness.java | 44 ++-
...syncKeyedTwoInputStreamOperatorTestHarness.java | 45 ++-
.../asyncprocessing/AsyncProcessingTestUtil.java | 12 +
.../apache/flink/state/forst/ForStMapState.java | 27 +-
.../test/streaming/runtime/IntervalJoinITCase.java | 333 +++++++++++--------
20 files changed, 656 insertions(+), 530 deletions(-)
copy
flink-runtime/src/main/java/org/apache/flink/{streaming/api/operators/co/IntervalJoinOperator.java
=> runtime/asyncprocessing/operators/AsyncIntervalJoinOperator.java} (58%)
copy
flink-runtime/src/test/java/org/apache/flink/{streaming/api/operators/co/IntervalJoinOperatorTest.java
=> runtime/asyncprocessing/operators/AsyncIntervalJoinOperatorTest.java} (93%)
