基本同標準的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");