1. 官方示例

Flink程序的第一步是创建StreamExecutionEnvironment，如果是编写批处理作业，则创建ExecutionEnvironment。
env.addSource()方法将数据源添加到流式拓扑。方法参数需要实现SourceFunction<T>接口，并且实现如下2个方法：

void run(SourceFunction.SourceContext<T> var1) throws Exception;
void cancel();

源的并行度为1。要启用并行执行，用户定义的源应实现ParallelSourceFunction或扩展RichParallelSourceFunction。