Flink数据源拆解分析(WikipediaEditsSource)_Java