GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/1273
[FLINK-2877] Move Streaming API out of Staging package
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/flink stream-out-of-staging
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/1273.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1273
----
commit 444226970e31856787fbebdd7793805293faf13b
Author: Aljoscha Krettek <[email protected]>
Date: 2015-10-11T09:37:29Z
[FLINK-2864] Make State of General-Purpose Window Operators Fault-Tolerant
This adds method state() on Trigger context that should be used to
create an OperatorState to deal with fault-tolerant state.
WindowAssigner now has a method getWindowSerializer() that is used to
get a TypeSerializer for the Windows that it assigns. The Serializer for
the Key is retrieved from the input KeyedStream and the serializer for
the input elements is already available.
During checkpointing all currently in-flight windows (per key, per
window) are serialized using the TypeSerializers. The state that is
accessible in Triggers using state() is kept in a
HashMap<String, Serializable>, this is serialized using java
serialization.
commit f760b616af0e1608cb4c190aeb264da72f624f4c
Author: Aljoscha Krettek <[email protected]>
Date: 2015-10-17T11:35:24Z
Replace Trigger.onTime by Trigger.onProcessingTime/onEventTime
This also renames WatermarkTrigger to EventTimeTrigger and
ContinuousWatermarkTrigger to ContinuousEventTimeTrigger.
commit b697080673d37deb1aafc17180207c6f8871e409
Author: Rufus Refactor <[email protected]>
Date: 2015-10-20T15:04:21Z
[FLINK-2877] Move Streaming API out of Staging package
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
