文章
2023-01-18
来自：开发者社区
【Flume中间件】（13）自定义Source
自定义Source有时候，flume中的source不符合我们的需求，这时就可以进行自己定义Source。自定义Source的流程就是首先继承并实现官方类，然后实现相应的方法，重点是读取数据的方法，在该内部可以定义jdbc或者是IO流进行读取数据。然后将数据封装成事件，交给channel处理器。处理器的内部流程是先将该事件交给拦截器进行处理（封装头部信息等），然后判断是否为空，不为空，将其将给选....
本页面内关键词为智能算法引擎基于机器学习所生成，如有任何问题，可在页面下方点击"联系我们"与我们沟通。