flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Srikanth <srikanth...@gmail.com>
Subject writeAsCSV with partitionBy
Date Fri, 12 Feb 2016 19:53:09 GMT

Is there a Hive(or Spark dataframe) partitionBy equivalent in Flink?

I'm looking to save output as CSV files partitioned by two columns(date and

The partitionBy dataset API is more to partition the data based on a column
for further processing.

I'm thinking there is no direct API to do this. But what will be the best
way of achieving this?


View raw message