本文介绍了实施水槽水槽的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！
问题描述
因此，我需要实现自己的Flume Sink.我经历了这个链接，但是我唯一缺少的部分是，我到底要做什么?我的Java实现完成了吗?编译成.class吗?罐?以及如何配置Flume以使用我的自定义接收器?
So, I need to implement my own Flume sink. I went through this link, but my only missing part is, what do I exactly do once I am done with my Java implementation? Compile it into a .class? JAR? and how to I configure Flume to use my custom sink?
谢谢
推荐答案
将其编译并打包到jar中.然后将罐子放入<apache flume install dir>/lib.然后，您可以在接收器定义中使用全限定名称来引用您的类.
Compile it and package it into a jar. Then put the jar in <apache flume install dir>/lib. Then you can refer to your class with its fully qualified name in a sink definition.
这篇关于实施水槽水槽的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！