ES中,有一類參數(shù)是可以動態(tài)調(diào)整的,比如副本數(shù)量: number_of_replicas
。
在插件開發(fā)中,如何添加自己的自定義參數(shù)呢?
在插件的入口,添加onModule(ClusterModule module)
即可。
創(chuàng)新互聯(lián)建站是一家專業(yè)提供濟(jì)南企業(yè)網(wǎng)站建設(shè),專注與成都做網(wǎng)站、網(wǎng)站設(shè)計(jì)、H5建站、小程序制作等業(yè)務(wù)。10年已為濟(jì)南眾多企業(yè)、政府機(jī)構(gòu)等服務(wù)。創(chuàng)新互聯(lián)專業(yè)網(wǎng)站制作公司優(yōu)惠進(jìn)行中。
public class ShgyPlugin extends Plugin {
@Override
public String name() {
return "shgy-plugin";
}
@Override
public String description() {
return "shgy plugin ";
}
public void onModule(ClusterModule module){
module.registerIndexDynamicSetting("index.custom_setting", new Validator() {
@Override
public String validate(String setting, String value, ClusterState clusterState) {
if (value == null) {
throw new NullPointerException("value must not be null");
}
return null;
}
});
}
}
編譯代碼,安裝插件后,使用如下的腳本測試:
curl -X PUT "localhost:9200/twitter/_settings" -H 'Content-Type: application/json' -d'
{
"index" : {
"custom_setting" : 2
}
}'
curl -XGET 'http://localhost:9200/twitter/_settings?pretty'
在代碼中使用參數(shù),一般是在TransportAction中使用, 代碼片段如下:
ClusterState clusterState = clusterService.state();
clusterState.blocks().globalBlockedRaiseException(ClusterBlockLevel.READ);
String concreteSingleIndex = indexNameExpressionResolver.concreteSingleIndex(clusterState, request);
IndexMetaData indexMeta = clusterState.getMetaData().index(concreteSingleIndex);
int sectionCnt = indexMeta.getSettings().getAsInt("index.custom_settings",-1);
即通過clusterService獲取到clusterState, 然后獲取到IndexMetaData, 然后獲取到Settings。
自定義動態(tài)參數(shù), 配合templates的使用,就不需要頻繁手動創(chuàng)建索引了。 這個知識點(diǎn)應(yīng)該歸納到 ES插件開發(fā)的一部分。
網(wǎng)站標(biāo)題:ES插件開發(fā)之--如何添加自己的動態(tài)設(shè)置項(xiàng)
本文來源:http://chinadenli.net/article44/gdoeee.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供網(wǎng)站改版、域名注冊、自適應(yīng)網(wǎng)站、搜索引擎優(yōu)化、響應(yīng)式網(wǎng)站、外貿(mào)網(wǎng)站建設(shè)
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)