混合框架apache flink的怎么安装

Question

混合框架apache flink的怎么安装

Answer 1

基本同标准的Java程序类似，并且含有一个main()方法。每个程序基本由以下5个部分组成：
获取一个ExecutionEnvironment
载入或者创建初始输入数据
指定数据变换的方式
制定计算后的数据输出位置
程序执行

对照上面的WordCountExample：
获取一个ExecutionEnvironment
final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();

初始数据：

DataSet<String> text = env.fromElements(
"Who's there?",
"I think I hear them. Stand, ho! Who's there?");
变换方式：

DataSet<Tuple2<String, Integer>> wordCounts = text
.flatMap(new LineSplitter())
.groupBy(0)
.sum(1);
输出方式

wordCounts.print();
程序执行

env.execute("Word Count Example");