Custom

在Flink 流计算中，提供数据源Source接口，用户实现自定义数据源，可以从任何地方获取数据，有两大类实现方式：

1. 通过实现SourceFunction接口或者继承RichSourceFunction(多功能)来自定义无并行度（也就是并行度只能为1）的Source。

   

2. 通过实现ParallelSourceFunction接口或者继承RichParallelSourceFunction(多功能)来自定义有并行度的数据源。

run方法 实时从数据源端加载数据，并且发送给下一个Operator算子，进行处理。 实时产生数据

cancel方法 当将Job作业取消时，不再从数据源端读取数据

总结：当基于数据源接口自定义数据源时，只需要实现上述2个方法即可。