GitHub user mbalassi opened a pull request:
https://github.com/apache/incubator-flink/pull/282
Update for Release 0.8 including the streaming scala API
Cherry-picked the streaming scala api commits. I've also added the recent
(non-streaming) documentation updates here that should go to the release.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mbalassi/incubator-flink release-0.8
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/incubator-flink/pull/282.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 #282
----
commit b2271bd9eb3adc1770f40d452ed7fb69614ea649
Author: Gyula Fora <[email protected]>
Date: 2015-01-02T17:33:46Z
[streaming] Time trigger preNotify fix
commit 6b1fd156a774a8292dd2e9227d611dcca5b9c526
Author: Gyula Fora <[email protected]>
Date: 2014-12-11T14:22:03Z
[scala] [streaming] Base functionality added for streaming scala api
Conflicts:
flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
commit 40efecf7cf79deb02f070bedc9980c91886b66ef
Author: Gyula Fora <[email protected]>
Date: 2014-12-11T23:12:49Z
[scala] [streaming] Extended scala data stream functionality to include
simple operators
commit d1b53b16695231f54d912d847c11a406523c8d5b
Author: Gyula Fora <[email protected]>
Date: 2014-12-13T00:08:08Z
[scala] [streaming] Finished scala StreamExecutionEnvrionment functionality
+ DataStream sinks + docs
Conflicts:
flink-addons/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/WriteAsCsvTest.java
flink-addons/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/WriteAsTextTest.java
commit e0ab48988d22ba2a38a8e6e43d9ede6215fdddb5
Author: Gyula Fora <[email protected]>
Date: 2014-12-15T15:21:00Z
[scala] [streaming] Windowing functionality added to scala api
commit a4c4f26e70088ed5cd5bf8a8f01585f09674cf04
Author: mbalassi <[email protected]>
Date: 2014-12-15T13:15:35Z
[scala] [streaming] Added SplitDataStream functionality
Conflicts:
flink-scala/src/main/scala/org/apache/flink/api/scala/streaming/DataStream.scala
commit 1922dbdb78019136310f0214395a9b0de27bbc49
Author: Gyula Fora <[email protected]>
Date: 2014-12-18T21:46:00Z
[scala] [streaming] Added support for iterative streams for scala api
commit 652327be3a1196fd98e18a777a24e36e6574da28
Author: Gyula Fora <[email protected]>
Date: 2014-12-19T20:05:01Z
[streaming] Temporal join and cross rework for consistence and extended
features
commit 739fdf0b76560f96b1b2dd9d9dbfba6eff1170bc
Author: Gyula Fora <[email protected]>
Date: 2014-12-20T17:12:19Z
[scala] [streaming] Temporal join operator added
commit 40a3b6bc35ceff115a549f6094602d64b6eb69e9
Author: Gyula Fora <[email protected]>
Date: 2014-12-20T18:34:55Z
[scala] [streaming] Temporal cross operator added
commit f7291ea1c9fa4a0484ab6bc13e4a594ff6d7c2d2
Author: Gyula Fora <[email protected]>
Date: 2014-12-20T22:46:35Z
[scala] [streaming] Modified aggregations to work on scala tuples
commit 1f7b6eaaa979e91799a047f29881f82666c12b19
Author: Gyula Fora <[email protected]>
Date: 2014-12-21T00:05:40Z
[scala] [streaming] Fixed scala formatting
commit 141348426eeae2ea0e4404a0d8cff8182c601886
Author: Gyula Fora <[email protected]>
Date: 2014-12-21T02:54:30Z
[scala] [streaming] Added groupBy support for case class fields
commit c6b90eed5e2a3e1ce51bdca436a2bebc06a87ca7
Author: Gyula Fora <[email protected]>
Date: 2014-12-21T12:10:34Z
[scala] [streaming] WindowJoin scala example added
commit 59952489b0d9036e5ff91374a85760005ee16d63
Author: Gyula Fora <[email protected]>
Date: 2014-12-23T20:16:46Z
[streaming] Streaming API grouping rework to use batch api Keys
Conflicts:
flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/util/ClusterUtil.java
commit 1492e96670b6450e0c24ea31fe66d77c7d6a9c64
Author: Gyula Fora <[email protected]>
Date: 2015-01-02T19:04:51Z
[scala] [streaming] Added scala window helpers + timestamp rework for
lambda support
Conflicts:
flink-addons/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/WindowCrossJoinTest.java
commit c34f5a77026ff491cabc2b5087b1c16da9e276a2
Author: Gyula Fora <[email protected]>
Date: 2015-01-03T18:41:37Z
[scala] [streaming] Added implicit conversions from java to scala streams
commit e1fa9b5db33bf5167e1cd56de862f482dd10c614
Author: senorcarbone <[email protected]>
Date: 2015-01-02T10:15:49Z
[scala] [streaming] added group windowing example with different policy
types
[scala] [streaming] updated example with scala delta helper usage
commit b094d49a3a0ac2d53698837f215e69372f2f963f
Author: carbone <[email protected]>
Date: 2015-01-03T18:46:22Z
[scala] [streaming] added initial ConnectedDataStream support (no
windowing,batching) for the scala api
commit 7eaf726aeab1ac461e934a4b9d5f87404a64bc0d
Author: carbone <[email protected]>
Date: 2015-01-03T19:00:13Z
[scala] [streaming] Added connect op to DataStream and implicit conversion
for ConnectedDataStreams
[scala] [streaming] Changed return types to implicits
commit e0fd9dfd0e884251f56965a416e60df0902cd2c7
Author: Gyula Fora <[email protected]>
Date: 2014-12-23T21:13:22Z
[streaming] Source parallelism + connector rework
commit 380934b1beb3a27a2ca3b99bc03ca7a10905589d
Author: Gyula Fora <[email protected]>
Date: 2014-12-25T17:00:26Z
[streaming] Updated connector type handling to suport generic classes by
GenericSourceFunction interface
commit bf85c0088bb0e3198819b86aeffc5376fa3d52b7
Author: mbalassi <[email protected]>
Date: 2015-01-04T11:44:16Z
[streaming] [scala] Restructured streaming scala project and examples
Amended for the release-0.8 branch
commit 232b0ebba1a24a9637f8cf8bcf979ee7784ffa15
Author: Erich Schubert <[email protected]>
Date: 2015-01-02T18:56:57Z
[docs] Trivial typo in example code: o -> out.
This closes #280
commit e78c453f53ce55e44b98301e9562104165a7e77d
Author: Stephan Ewen <[email protected]>
Date: 2015-01-04T22:08:55Z
[FLINK-1338] [docs] Remove incubator footer from docs
commit e3700c3707559c19b0f05cb48589ef7311b63e08
Author: Stephan Ewen <[email protected]>
Date: 2015-01-04T22:09:26Z
[docs] Remove files from obolete and unused figures
commit fb86fde2b94d53e133efa542520a48d220e168a9
Author: Gyula Fora <[email protected]>
Date: 2015-01-05T14:24:59Z
[streaming] Temporal operator windowing syntax update
Conflicts:
flink-addons/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/WindowCrossJoinTest.java
commit fcd28fccd38a070f69676f48b2038af9c6e5eb4e
Author: Gyula Fora <[email protected]>
Date: 2015-01-05T14:59:50Z
[streaming] Deleted obsolete parts of the connected stream api
commit acd2d601e89e336c17c87bcb51461be0a4db5340
Author: Gyula Fora <[email protected]>
Date: 2015-01-05T17:26:18Z
[streaming] Updated streaming guide for recent connector and data source
changes
----
---
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.
---
