java - カスタムリバーを書く

Question

川を書くのは初めてです。（ソースコードはこちら）

私はこのチュートリアルに従い、この既存の川と比較しましたが、うまくいきませんでした。

リバーをデプロイするために、 というフォルダーを作成し、example-riverそのフォルダーに jar をドロップして、ノードを再起動しました。すべてが正常に起動します。

私も試してみbin/plugin --url file:///path/to/plugin --install example-riverましたが、うまくいくようですが、jarファイルを解凍します。

この PUT リクエストを発行すると:

http://localhost:9200/_river/example_river/_meta
{
    "type": "example_river",
  "example_river":{
    "blah":"blah"
  }
}

私はこの例外を受け取ります:

[2014-04-20 22:28:46,538][デバッグ][川] [グルーム] 川 [example_river][example_river] [2014-04-20 22:28:46,543][警告][川] [グルーム]川を作成できませんでした [example_river] [example_river] org.elasticsearch.common.settings.NoClassSettingsException: org.elasticsearch.river.RiverModule.loadTypeModule(RiverModule.java:87) で値 [example_river] を持つクラスを読み込めませんでした org.elasticsearch .river.RiverModule.spawnModules(RiverModule.java:58) で org.elasticsearch.common.inject.ModulesBuilder.add(ModulesBuilder.java:44) で org.elasticsearch.river.RiversService.createRiver(RiversService.java:137) でorg.elasticsearch.river.RiversService$ApplyRivers$2.onResponse(RiversService.java:275) at org.elasticsearch.river.RiversService$ApplyRivers$2.onResponse(RiversService.java:269) at org.elasticsearch.action.support.TransportAction$ThreadedActionListener$1.run(TransportAction.java:93) at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) at java.util.concurrent .ThreadPoolExecutor$Worker.run(不明なソース) で java.lang.Thread.run(不明なソース) 原因: java.lang.ClassNotFoundException: example_river で java.net.URLClassLoader$1.run(不明なソース) で java.net. java.security.AccessController.doPrivileged(Native Method) の URLClassLoader$1.run(不明なソース) java.net.URLClassLoader.findClass(不明なソース) の java.lang.ClassLoader.loadClass(不明なソース) の sun.misc.Launcher org.elasticsearch.river.RiverModule の java.lang.ClassLoader.loadClass(不明なソース) の $AppClassLoader.loadClass(不明なソース)。loadTypeModule(RiverModule.java:73) ... 9 もっと見る

誰かが私が欠けているものを指摘できますか?