I'm highly encouraging you to read through the examples and Batch API
documentation:
https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/batch/#example-program
https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/batch/dataset_transformations.html#dataset-transformations
TL;DR: apply a map function to the transactions DataSet
On 15.11.2018 13:42, Mar_zieh wrote:
Hello guys
I have wrote this code. I could print the whole file, but I want to read the
file line by line and process each line separately. would you please help
how I can do that?
ExecutionEnvironment env = ExecutionEnvironment.createLocalEnvironment();
DataSet<String> transactions =
env.readTextFile("/home/cfms11/Downloads/Data.csv");
transactions.print();
Thank you in advance.
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
