I solve error when use import
org.apache.flink.api.java.io.TextOutputFormat.TextFormatter;
very thanks
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/want-write-Specified-field-from-dataset-to-output-file-tp1223p1226.html
Sent from the Apach
when use the solve display error message
cannot find symbol
new TextFormatter() {
symbol: class TextFormatter
location: class TPCHQuery3
Note:
/home/hadoop/Desktop/sub_query/src/org/apache/flink/examples/java/relational/TPCHQuery3.java
uses unchecked or unsafe operations.
Note: Recompile with -Xl
Hi,
please have a look at the programming guide on how to write results to an
output file:
http://ci.apache.org/projects/flink/flink-docs-master/apis/programming_guide.html#data-sinks
In your case, I would recommend:
customers.writeAsFormattedText("file:///path/to/the/result/file",
new TextF
