[GitHub] flink pull request: [FLINK-2877] Move Streaming API out of Staging...

[aljoscha]

Github user aljoscha commented on the pull request:

https://github.com/apache/flink/pull/1273#issuecomment-149828351
  
Manually merged 


---
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 infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink pull request: [FLINK-2877] Move Streaming API out of Staging...

[aljoscha]

Github user aljoscha closed the pull request at:

https://github.com/apache/flink/pull/1273


---
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 infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink pull request: [FLINK-2877] Move Streaming API out of Staging...

[fhueske]

Github user fhueske commented on the pull request:

https://github.com/apache/flink/pull/1273#issuecomment-149657090
  
+1 for `flink-streaming-java` and `flink-streaming-scala`


---
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 infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink pull request: [FLINK-2877] Move Streaming API out of Staging...

[StephanEwen]

Github user StephanEwen commented on the pull request:

https://github.com/apache/flink/pull/1273#issuecomment-149637552
  
Looks pretty straightforward. Some diffs are displayed probably because of 
git bugs / limitations. As this was discussed on the mailing list before and 
all agreed, this should be good.

Only point of discussion could be names. I personally like the names 
`flink-streaming-java` and `flink-streaming-scala`, so +1 from my side


---
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 infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink pull request: [FLINK-2877] Move Streaming API out of Staging...

[StephanEwen]

Github user StephanEwen commented on the pull request:

https://github.com/apache/flink/pull/1273#issuecomment-149636785
  
GitHub sync is lagging behind, so only one commit (the latest) in the PR is 
relevant, the others are already committed.


---
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 infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink pull request: [FLINK-2877] Move Streaming API out of Staging...

[aljoscha]

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 
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, this is serialized using java
serialization.

commit f760b616af0e1608cb4c190aeb264da72f624f4c
Author: Aljoscha Krettek 
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 
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 infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---