混合框架apache flink的怎么安装

混合框架apache flink的怎么安装

基本同标准的Java程序类似,并且含有一个main()方法。每个程序基本由以下5个部分组成:

获取一个ExecutionEnvironment

载入或者创建初始输入数据

指定数据变换的方式

制定计算后的数据输出位置

程序执行

对照上面的WordCountExample:

获取一个ExecutionEnvironment

final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();

初始数据:

DataSet text = env.fromElements(

"Who's there?",

"I think I hear them. Stand, ho! Who's there?");

变换方式:

DataSet> wordCounts = text

.flatMap(new LineSplitter())

.groupBy(0)

.sum(1);

输出方式

wordCounts.print();

程序执行

env.execute("Word Count Example");