Github user HuangWHWHW commented on the pull request:
https://github.com/apache/flink/pull/1098#issuecomment-138449988
I take a fix for the consistent to JAVA and SCALA APIs.
As a result, we can call `writeAsText` and `writeAsCsv` method with:
*path
*path, write frequency
*path, writemode
*path. writemode, write frequency
And I add tests for these APIs.
And I noticed that in JAVA API, `writeAsCsv` cannot be configured the
`Delimiter` for a row or a filed while the SCALA API is able.
I'm not sure neither to remove the feature in Scala API nor add it to the
Java API.
So I added a new `writeAsCsv` method in Java DataStream for that we can
configure the `Delimiter`.
---
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.
---
