[
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 <[email protected]>
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 <[email protected]>
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 <[email protected]>
Date: 2014-12-16T21:49:58Z
[streaming] Updated deprecated iterative functionality and docs
commit 1ac9651abff2760a2a66c6cce0e3aa2e1bf5d1dd
Author: twalthr <[email protected]>
Date: 2014-12-10T21:02:07Z
Fix invalid type hierarchy creation by Pojo logic
commit a835e5dfb97624f3132761c7933aaffb03b0d06f
Author: Robert Metzger <[email protected]>
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 <[email protected]>
Date: 2014-12-16T21:00:50Z
[FLINK-1333] Fixed getter/setter recognition for POJOs
This closes #271
commit 02bad15318da525f6db938a41cd10c7203156314
Author: mbalassi <[email protected]>
Date: 2014-12-17T15:46:01Z
[FLINK-1325] [streaming] Added clousure cleaning to streaming
This closes #273
commit 6f481ce785b9d4a9824b9d7c82e18342bbeaf897
Author: Till Rohrmann <[email protected]>
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 <[email protected]>
Date: 2014-12-18T14:28:54Z
[FLINK-1336] [core] Fix bug in StringValue binary copy method
commit 88f38e49202354926cb4ec36390cbe34bad247a3
Author: Gyula Fora <[email protected]>
Date: 2014-12-17T22:34:26Z
[streaming] StreamInvokable rework for simpler logic and easier use
commit 2ac49856ac8a3aa42912b1e74a7109792c5b93aa
Author: mbalassi <[email protected]>
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 <[email protected]>
Date: 2014-12-18T13:52:15Z
[streaming] Added immutability for window and filter operators
commit cadc9cce0bbfa2615ed746a6b0372f21e042a945
Author: Jonas Traub (powibol) <[email protected]>
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 <[email protected]>
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 <[email protected]>
Date: 2014-12-26T17:02:55Z
[FLINK-1225] Fix for quickstart packaging
This closes #279
commit 2467f36c80830e83b43271c89cf1ec827882b424
Author: mbalassi <[email protected]>
Date: 2014-12-26T17:06:51Z
[streaming] Temporal fix for streaming source parallelism
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
----
> 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)
