[ https://issues.apache.org/jira/browse/FLINK-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14278333#comment-14278333 ]
ASF GitHub Bot commented on FLINK-1388: --------------------------------------- GitHub user msdevanms opened a pull request: https://github.com/apache/flink/pull/312 https://issues.apache.org/jira/browse/FLINK-1388 https://issues.apache.org/jira/browse/FLINK-1388 You can merge this pull request into a Git repository by running: $ git pull https://github.com/apache/flink release-0.8 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/312.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 #312 ---- commit a33ad5d8303295e57f0e6a8df3c071f010963029 Author: mbalassi <mbala...@apache.org> Date: 2014-12-16T11:48:09Z [streaming] DataStream print functionality update PrintSinkFunction now explicitly states threads in output Added printToErr functionality commit e34aca7545f4900725b470ff1ab2db4b48c2275f Author: mbalassi <mbala...@apache.org> Date: 2014-12-16T20:00:31Z [streaming] [examples] Refactor and packaging for windowing examples The current examples show-case the API, more meaningful examples are coming for the 0.9 release. commit c8e306b6567a4b615c54e8d8f88116ff6f1a0e38 Author: Gyula Fora <gyf...@apache.org> Date: 2014-12-16T21:49:58Z [streaming] Updated deprecated iterative functionality and docs commit 1ac9651abff2760a2a66c6cce0e3aa2e1bf5d1dd Author: twalthr <i...@twalthr.com> Date: 2014-12-10T21:02:07Z Fix invalid type hierarchy creation by Pojo logic commit a835e5dfb97624f3132761c7933aaffb03b0d06f Author: Robert Metzger <rmetz...@apache.org> Date: 2014-12-16T10:30:52Z [FLINK-610] Replace Avro by Kryo as the GenericType serializer The performance of data-intensive jobs using Kryo is probably going to be slow. Set correct classloader try to use Kryo.copy() with fallback to serialization copy commit 7ef04c625768515c874f3b015cf30f6631c4dade Author: Robert Metzger <metzg...@web.de> Date: 2014-12-16T21:00:50Z [FLINK-1333] Fixed getter/setter recognition for POJOs This closes #271 commit 02bad15318da525f6db938a41cd10c7203156314 Author: mbalassi <mbala...@apache.org> Date: 2014-12-17T15:46:01Z [FLINK-1325] [streaming] Added clousure cleaning to streaming This closes #273 commit 6f481ce785b9d4a9824b9d7c82e18342bbeaf897 Author: Till Rohrmann <trohrm...@apache.org> Date: 2014-12-18T10:37:23Z Fixes race condition in ExecutionGraph which allowed a job to go into the finished state without all job vertices having properly processed the finalizeOnMaster method. commit 15fb1da9907cc549ddb94f191fba11618f546854 Author: Stephan Ewen <se...@apache.org> Date: 2014-12-18T14:28:54Z [FLINK-1336] [core] Fix bug in StringValue binary copy method commit 88f38e49202354926cb4ec36390cbe34bad247a3 Author: Gyula Fora <gyf...@apache.org> Date: 2014-12-17T22:34:26Z [streaming] StreamInvokable rework for simpler logic and easier use commit 2ac49856ac8a3aa42912b1e74a7109792c5b93aa Author: mbalassi <mbala...@apache.org> Date: 2014-12-17T23:28:07Z [dist] Updated the assembly of the examples subdirectory Excluded the scala example jars Excluded the example source code subdirectories This closes #274 commit 446cc1253554f924664d7fe753f3cee46ee87c13 Author: Gyula Fora <gyf...@apache.org> Date: 2014-12-18T13:52:15Z [streaming] Added immutability for window and filter operators commit cadc9cce0bbfa2615ed746a6b0372f21e042a945 Author: Jonas Traub (powibol) <j...@s-traub.com> Date: 2014-12-18T15:11:16Z [streaming] Make windowed data stream aware of time based trigger/eviction in tumbling window situations. [streaming] Changed TimeEvictionPolicy to keep timestamps in the buffer instead of data-items commit 9555c827f8b354722f6865d531f3fccd400c0015 Author: mbalassi <mbala...@apache.org> Date: 2014-12-19T22:34:02Z [FLINK-1338] Updates necessary due to Apache graduation Removed Disclaimer file Eliminated unnecessary incubating substrings Bumped version to 0.8-SNAPSHOT commit 6b3c3a1780b1270226a76f6a81a9ad2029578a7a Author: mbalassi <mbala...@apache.org> Date: 2014-12-26T17:02:55Z [FLINK-1225] Fix for quickstart packaging This closes #279 commit 2467f36c80830e83b43271c89cf1ec827882b424 Author: mbalassi <mbala...@apache.org> Date: 2014-12-26T17:06:51Z [streaming] Temporal fix for streaming source parallelism commit b2271bd9eb3adc1770f40d452ed7fb69614ea649 Author: Gyula Fora <gyf...@apache.org> Date: 2015-01-02T17:33:46Z [streaming] Time trigger preNotify fix commit 6b1fd156a774a8292dd2e9227d611dcca5b9c526 Author: Gyula Fora <gyf...@apache.org> 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 <gyf...@apache.org> Date: 2014-12-11T23:12:49Z [scala] [streaming] Extended scala data stream functionality to include simple operators commit d1b53b16695231f54d912d847c11a406523c8d5b Author: Gyula Fora <gyf...@apache.org> 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 <gyf...@apache.org> Date: 2014-12-15T15:21:00Z [scala] [streaming] Windowing functionality added to scala api commit a4c4f26e70088ed5cd5bf8a8f01585f09674cf04 Author: mbalassi <mbala...@apache.org> 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 <gyf...@apache.org> Date: 2014-12-18T21:46:00Z [scala] [streaming] Added support for iterative streams for scala api commit 652327be3a1196fd98e18a777a24e36e6574da28 Author: Gyula Fora <gyf...@apache.org> Date: 2014-12-19T20:05:01Z [streaming] Temporal join and cross rework for consistence and extended features commit 739fdf0b76560f96b1b2dd9d9dbfba6eff1170bc Author: Gyula Fora <gyf...@apache.org> Date: 2014-12-20T17:12:19Z [scala] [streaming] Temporal join operator added commit 40a3b6bc35ceff115a549f6094602d64b6eb69e9 Author: Gyula Fora <gyf...@apache.org> Date: 2014-12-20T18:34:55Z [scala] [streaming] Temporal cross operator added commit f7291ea1c9fa4a0484ab6bc13e4a594ff6d7c2d2 Author: Gyula Fora <gyf...@apache.org> Date: 2014-12-20T22:46:35Z [scala] [streaming] Modified aggregations to work on scala tuples commit 1f7b6eaaa979e91799a047f29881f82666c12b19 Author: Gyula Fora <gyf...@apache.org> Date: 2014-12-21T00:05:40Z [scala] [streaming] Fixed scala formatting commit 141348426eeae2ea0e4404a0d8cff8182c601886 Author: Gyula Fora <gyf...@apache.org> Date: 2014-12-21T02:54:30Z [scala] [streaming] Added groupBy support for case class fields commit c6b90eed5e2a3e1ce51bdca436a2bebc06a87ca7 Author: Gyula Fora <gyf...@apache.org> Date: 2014-12-21T12:10:34Z [scala] [streaming] WindowJoin scala example added ---- > POJO support for writeAsCsv > --------------------------- > > Key: FLINK-1388 > URL: https://issues.apache.org/jira/browse/FLINK-1388 > Project: Flink > Issue Type: New Feature > Components: Java API > Reporter: Timo Walther > Priority: Minor > > It would be great if one could simply write out POJOs in CSV format. > {code} > public class MyPojo { > String a; > int b; > } > {code} > to: > {code} > # CSV file of org.apache.flink.MyPojo: String a, int b > "Hello World", 42 > "Hello World 2", 47 > ... > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)