This is an automated email from the ASF dual-hosted git repository.
tzulitai pushed a change to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 9dec1aa [FLINK-13274]Refactor HiveTableSourceTest using HiveRunner
new 752e7ae [FLINK-13293] [state-processor-api] [build] Add state
processor api to opt/ directory in flink-dist
new 7d546b6 [FLINK-13094][state-processor-api] Support iterating over
registered timers in the internal timer service
new b8eec2b [FLINK-13094][state-processor-api] Add registered*TimeTimers
methods to KeyedStateReaderFunction#Context for querying the registered timers
for a given key
The 3 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-dist/pom.xml | 7 ++
flink-dist/src/main/assemblies/opt.xml | 8 ++
.../api/functions/KeyedStateReaderFunction.java | 12 +++
.../state/api/input/KeyedStateInputFormat.java | 92 ++++++++++++++++++++-
.../state/api/SavepointReaderKeyedStateITCase.java | 93 +++++++++++++++++-----
.../state/api/input/KeyedStateInputFormatTest.java | 43 ++++++++++
.../api/operators/InternalTimerService.java | 13 +++
.../api/operators/InternalTimerServiceImpl.java | 21 +++++
.../streaming/api/operators/TimerSerializer.java | 4 +-
.../operators/InternalTimerServiceImplTest.java | 79 ++++++++++++++++++
.../api/operators/TestInternalTimerService.java | 17 ++++
11 files changed, 367 insertions(+), 22 deletions(-)
