Hi, the RollingSink can only be used with streaming. Adding support for dynamic paths based on element contents is certainly interesting. I imagine it can be tricky, though, to figure out when to close/flush the buckets.
Cheers, Aljoscha On Wed, 25 May 2016 at 08:36 KirstiLaurila <kirsti.laur...@rovio.com> wrote: > Maybe, I don't know, but with streaming. How about batch? > > > Srikanth wrote > > Isn't this related to -- > https://issues.apache.org/jira/browse/FLINK-2672 > > ?? > > > > This can be achieved with a RollingSink[1] & custom Bucketer probably. > > > > [1] > > > https://ci.apache.org/projects/flink/flink-docs-master/api/java/org/apache/flink/streaming/connectors/fs/RollingSink.html > > > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/writeAsCSV-with-partitionBy-tp4893p7140.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >
