草庐IT

fromSource

全部标签

flink之addSource & fromSource 、addSink & SinkTo

一、addSource&fromSource、addSink&SinkTo    这两组算子区别在于:addSource和addSink需要自己实现SourceFunction或者是SinkFunction,其中读取数据的逻辑,容错等都需要自己实现;fromSource和SinkTo,是flink提供的简易的读取和输出的算子,建议优先使用fromSource和SinkTo,并结合flink官方文档;二、filesystemsource算子1.readTextFile(filePath:String,charsetName:String):底层调用的是readFile(format,filePa