This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 5aedb83 [FLINK-16692] Register custom JobListeners throug config.
new 89ceb2a [FLINK-16316][task] Remove StreamTask dependency from
AbstractStreamOperator#snapshotState
new c5eb0e5 [FLINK-16316][operators] Remove chaining strategy methods
from the StreamOperator interface
new cb4c32f [FLINK-16316][operators] Pass StreamTaskStateInitializer to
operators from outside
new 63d6add [hotfix][test] Fix formatting in AbstractStreamOperatorTest
new a909af1 [hotfix][test] Remove no-op tests for AbstractStreamOperator
new 7e7bcc4 [FLINK-16316][operators] Extract state handling code from
AbstractStreamOperator
new 239088e [FLINK-16316][operators] Cut dependency between
StreamingRuntimeContext and AbstractStreamOperator
new c1398f0 [FLINK-16316][operators] Move inner CountingClass class out
from AbstractStreamOperator
new f84cc1b [FLINK-16316][operators] Introduce StreamOperatorParameters
class
new 16a0334 [FLINK-16316][operators] Implement new
AbstractStreamOperatorV2 as a replacement for AbstractStreamOperator
new 73d4103 [FLINK-16316][operators] Make StreamOperatorFactory
Experimental
The 11 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/state/api/output/BoundedStreamTask.java | 2 +-
.../flink/state/api/output/SnapshotUtilsTest.java | 15 +-
.../runtime/state/AbstractKeyedStateBackend.java | 5 +
.../state/StateSnapshotContextSynchronousImpl.java | 4 +-
.../operators/testutils/ExpectedTestException.java | 4 +-
.../ContinuousFileReaderOperatorFactory.java | 10 +-
.../api/operators/AbstractStreamOperator.java | 364 +++------------
.../operators/AbstractStreamOperatorFactory.java | 2 +
.../api/operators/AbstractStreamOperatorV2.java | 507 +++++++++++++++++++++
.../streaming/api/operators/CountingOutput.java} | 44 +-
.../api/operators/InternalTimeServiceManager.java | 64 +++
.../api/operators/SetupableStreamOperator.java | 4 +
.../api/operators/SimpleOperatorFactory.java | 19 +-
.../streaming/api/operators/StreamOperator.java | 6 +-
.../api/operators/StreamOperatorFactory.java | 9 +-
.../api/operators/StreamOperatorFactoryUtil.java | 8 +-
.../api/operators/StreamOperatorParameters.java | 67 +++
.../api/operators/StreamOperatorStateHandler.java | 310 +++++++++++++
.../api/operators/StreamingRuntimeContext.java | 63 ++-
.../api/operators/YieldingOperatorFactory.java | 3 +
.../operators/async/AsyncWaitOperatorFactory.java | 10 +-
.../runtime/tasks/CheckpointingOperation.java | 33 +-
.../streaming/runtime/tasks/OperatorChain.java | 14 +-
.../flink/streaming/runtime/tasks/StreamTask.java | 5 +-
.../api/graph/StreamGraphGeneratorTest.java | 6 +-
.../api/operators/AbstractStreamOperatorTest.java | 307 +++----------
.../AbstractUdfStreamOperatorLifecycleTest.java | 4 +-
.../operators/StreamOperatorStateHandlerTest.java | 193 ++++++++
.../api/operators/StreamingRuntimeContextTest.java | 126 +++--
.../runtime/operators/MailboxOperatorTest.java | 10 +-
.../operators/StreamTaskOperatorTimerTest.java | 12 +-
.../runtime/tasks/MultipleInputStreamTaskTest.java | 65 ++-
.../streaming/runtime/tasks/StreamTaskTest.java | 6 +-
.../util/AbstractStreamOperatorTestHarness.java | 2 +-
.../util/TestBoundedMultipleInputOperator.java | 8 +-
.../KeyedCoProcessOperatorWithWatermarkDelay.scala | 3 +-
.../KeyedProcessOperatorWithWatermarkDelay.scala | 3 +-
.../runtime/operators/CodeGenOperatorFactory.java | 17 +-
.../KeyedCoProcessOperatorWithWatermarkDelay.java | 8 +-
.../WatermarkAssignerOperatorFactory.java | 14 +-
.../streaming/runtime/MultipleInputITCase.java | 43 +-
.../runtime/StreamTaskSelectiveReadingITCase.java | 3 +-
42 files changed, 1602 insertions(+), 800 deletions(-)
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperatorV2.java
copy
flink-streaming-java/src/{test/java/org/apache/flink/streaming/util/CollectorOutput.java
=> main/java/org/apache/flink/streaming/api/operators/CountingOutput.java}
(55%)
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperatorParameters.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperatorStateHandler.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/StreamOperatorStateHandlerTest.java
