Input Input 定义所有的数据源(Source)，用于Pipeline.read()方法 实现一个Source需要实现四个接口： 有一个input_format属性，是一个flume::Loader 有一个objector属性，是一个Objector 有一个uris属性，返回一个uri列表 有一个transform_from_node方...