The Flink Scala API.
The Flink Scala API. org.apache.flink.api.scala.ExecutionEnvironment is the starting-point
of any Flink program. It can be used to read from local files, HDFS, or other sources.
org.apache.flink.api.scala.DataSet is the main abstraction of data in Flink. It provides
operations that create new DataSets via transformations.
org.apache.flink.api.scala.GroupedDataSet provides operations on grouped data that results
Use org.apache.flink.api.scala.ExecutionEnvironment.getExecutionEnvironment to obtain
an execution environment. This will either create a local environment or a remote environment,
depending on the context where your program is executing.