基本同標準的Java程序類似，并且含有一個main()方法。每個程序基本由以下5個部分組成：
獲取一個ExecutionEnvironment
載入或者創(chuàng)建初始輸入數(shù)據(jù)
指定數(shù)據(jù)變換的方式
制定計算后的數(shù)據(jù)輸出位置
程序執(zhí)行

對照上面的WordCountExample：
獲取一個ExecutionEnvironment
final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();

初始數(shù)據(jù)：

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();
程序執(zhí)行

env.execute("Word Count Example");