自定义插件类继承org.elasticsearch.plugins.Plugin
本文最简单的一个插件,在控制台打印信息:
package es.plugins;
import org.elasticsearch.plugins.ActionPlugin;
import org.elasticsearch.plugins.Plugin;
import java.util.Collections;
import java.util.List;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.elasticsearch.rest.RestHandler;
public class MyFirstPlugin extends Plugin implements ActionPlugin{
private final static Logger LOGGER = LogManager.getLogger(MyFirstPlugin.class);
public MyFirstPlugin() {
super();
LOGGER.info("This is my fisrt Plugin");
LOGGER.info("This is my fisrt Plugin");
LOGGER.info("This is my fisrt Plugin");
LOGGER.info("This is my fisrt Plugin");
LOGGER.info("This is my fisrt Plugin");
LOGGER.info("This is my fisrt Plugin");
LOGGER.info("This is my fisrt Plugin");
LOGGER.warn("Create the Basic Plugin and installed it into elasticsearch");
LOGGER.warn("Create the Basic Plugin and installed it into elasticsearch");
LOGGER.warn("Create the Basic Plugin and installed it into elasticsearch");
LOGGER.warn("Create the Basic Plugin and installed it into elasticsearch");
LOGGER.warn("Create the Basic Plugin and installed it into elasticsearch");
LOGGER.warn("Create the Basic Plugin and installed it into elasticsearch");
LOGGER.warn("Create the Basic Plugin and installed it into elasticsearch");
LOGGER.warn("Create the Basic Plugin and installed it into elasticsearch");
}
}
打包成jar包,在plugin目录下新建一个文件夹,然后放入jar包,添加配置文件plugin-descriptor.properties
文件内容如下
description=hello for ElasticSearch
version=1.0
name=HelloWorldPlugin
site=${elasticsearch.plugin.site}
jvm=true
classname=org.elasticsearch.plugin.helloworld.MyFirstPlugin //类全名
java.version=1.7
elasticsearch.version=2.2.0
isolated=${elasticsearch.plugin.isolated}