PROSAGA码农传奇-flume-Flume流到mysql

<div class =“post-text”itemprop =“text”>
  
    您总是可以为MySQL创建自定义接收器。这就是我们在FIWARE上所做的
    <a href="https://github.com/telefonicaid/fiware-cygnus" rel="nofollow noreferrer">
      天鹅
    </A>
     工具。
  
  
    随意从中获取灵感：
    <a href =“https://github.com/telefonicaid/fiware-cygnus/blob/master/cygnus-ngsi/src/main/java/com/telefonica/iot/cygnus/sinks/NGSIMySQLSink.java"rel =” nofollow noreferrer“>
      https://github.com/telefonicaid/fiware-cygnus/blob/master/cygnus-ngsi/src/main/java/com/telefonica/iot/cygnus/sinks/NGSIMySQLSink.java
    </A>
  
  
    它扩展了我们所有接收器的另一个自定义基类：
    <a href =“https://github.com/telefonicaid/fiware-cygnus/blob/master/cygnus-ngsi/src/main/java/com/telefonica/iot/cygnus/sinks/NGSISink.java"rel =” nofollow noreferrer“>
      https://github.com/telefonicaid/fiware-cygnus/blob/master/cygnus-ngsi/src/main/java/com/telefonica/iot/cygnus/sinks/NGSISink.java
    </A>
  
  
    基本上，你必须扩展
     <code>
 AbstractSink
 </code>
     并实施
     <code>
 Configurable
 </code>
     接口。这意味着至少要覆盖以下方法：
  
   <pre>
 <code>
 public Status process() throws EventDeliveryException

</code>
 </pre>
  
    和：
  
   <pre>
 <code>
 public void configure(Context context)

</code>
 </pre>
  
    分别。
  
</DIV>