Java IndexNameExpressionResolver类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.elasticsearch.cluster.metadata.IndexNameExpressionResolver类的典型用法代码示例。如果您正苦于以下问题：Java IndexNameExpressionResolver类的具体用法？Java IndexNameExpressionResolver怎么用？Java IndexNameExpressionResolver使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

IndexNameExpressionResolver类属于org.elasticsearch.cluster.metadata包，在下文中一共展示了IndexNameExpressionResolver类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: TestTransportBulkAction

import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver; //导入依赖的package包/类
TestTransportBulkAction(
        Settings settings,
        ThreadPool threadPool,
        TransportService transportService,
        ClusterService clusterService,
        TransportShardBulkAction shardBulkAction,
        TransportCreateIndexAction createIndexAction,
        ActionFilters actionFilters,
        IndexNameExpressionResolver indexNameExpressionResolver,
        AutoCreateIndex autoCreateIndex,
        LongSupplier relativeTimeProvider) {
    super(
            settings,
            threadPool,
            transportService,
            clusterService,
            null,
            shardBulkAction,
            createIndexAction,
            actionFilters,
            indexNameExpressionResolver,
            autoCreateIndex,
            relativeTimeProvider);
}

开发者ID:justor，项目名称:elasticsearch_my，代码行数:25，代码来源:TransportBulkActionTookTests.java

示例2: UpdateProjector

import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver; //导入依赖的package包/类
public UpdateProjector(ClusterService clusterService,
                       IndexNameExpressionResolver indexNameExpressionResolver,
                       Settings settings,
                       ShardId shardId,
                       TransportActionProvider transportActionProvider,
                       BulkRetryCoordinatorPool bulkRetryCoordinatorPool,
                       CollectExpression<Row, ?> collectUidExpression,
                       String[] assignmentsColumns,
                       Symbol[] assignments,
                       @Nullable Long requiredVersion,
                       UUID jobId) {
    super(clusterService, settings, shardId, transportActionProvider, bulkRetryCoordinatorPool,
            collectUidExpression, jobId);
    this.indexNameExpressionResolver = indexNameExpressionResolver;
    this.assignmentsColumns = assignmentsColumns;
    this.assignments = assignments;
    this.requiredVersion = requiredVersion;
}

开发者ID:baidu，项目名称:Elasticsearch，代码行数:19，代码来源:UpdateProjector.java

示例3: testUpdate

import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver; //导入依赖的package包/类
public void testUpdate() {
    boolean value = randomBoolean();
    Settings settings;
    if (value && randomBoolean()) {
        settings = Settings.EMPTY;
    } else {
        settings = Settings.builder().put(AutoCreateIndex.AUTO_CREATE_INDEX_SETTING.getKey(), value).build();
    }

    ClusterSettings clusterSettings = new ClusterSettings(settings,
            ClusterSettings.BUILT_IN_CLUSTER_SETTINGS);
    AutoCreateIndex  autoCreateIndex = new AutoCreateIndex(settings, clusterSettings, new IndexNameExpressionResolver(settings));
    assertThat(autoCreateIndex.getAutoCreate().isAutoCreateIndex(), equalTo(value));

    Settings newSettings = Settings.builder().put(AutoCreateIndex.AUTO_CREATE_INDEX_SETTING.getKey(), !value).build();
    clusterSettings.applySettings(newSettings);
    assertThat(autoCreateIndex.getAutoCreate().isAutoCreateIndex(), equalTo(!value));

    newSettings = Settings.builder().put(AutoCreateIndex.AUTO_CREATE_INDEX_SETTING.getKey(), "logs-*").build();
    clusterSettings.applySettings(newSettings);
    assertThat(autoCreateIndex.getAutoCreate().isAutoCreateIndex(), equalTo(true));
    assertThat(autoCreateIndex.getAutoCreate().getExpressions().size(), equalTo(1));
    assertThat(autoCreateIndex.getAutoCreate().getExpressions().get(0).v1(), equalTo("logs-*"));
}

开发者ID:justor，项目名称:elasticsearch_my，代码行数:25，代码来源:AutoCreateIndexTests.java

示例4: TransportNodesAction

import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver; //导入依赖的package包/类
protected TransportNodesAction(Settings settings, String actionName, ThreadPool threadPool,
                               ClusterService clusterService, TransportService transportService, ActionFilters actionFilters,
                               IndexNameExpressionResolver indexNameExpressionResolver,
                               Supplier<NodesRequest> request, Supplier<NodeRequest> nodeRequest,
                               String nodeExecutor,
                               Class<NodeResponse> nodeResponseClass) {
    super(settings, actionName, threadPool, transportService, actionFilters, indexNameExpressionResolver, request);
    this.clusterService = Objects.requireNonNull(clusterService);
    this.transportService = Objects.requireNonNull(transportService);
    this.nodeResponseClass = Objects.requireNonNull(nodeResponseClass);

    this.transportNodeAction = actionName + "[n]";

    transportService.registerRequestHandler(
        transportNodeAction, nodeRequest, nodeExecutor, new NodeTransportHandler());
}

开发者ID:justor，项目名称:elasticsearch_my，代码行数:17，代码来源:TransportNodesAction.java

示例5: TransportCancelTasksAction

import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver; //导入依赖的package包/类
@Inject
public TransportCancelTasksAction(Settings settings, ClusterName clusterName, ThreadPool threadPool, ClusterService clusterService,
                                  TransportService transportService, ActionFilters actionFilters, IndexNameExpressionResolver
                                      indexNameExpressionResolver) {
    super(settings, CancelTasksAction.NAME, clusterName, threadPool, clusterService, transportService, actionFilters,
        indexNameExpressionResolver, new Callable<CancelTasksRequest>() {
            @Override
            public CancelTasksRequest call() throws Exception {
                return new CancelTasksRequest();
            }
        }, ThreadPool.Names.MANAGEMENT);
    transportService.registerRequestHandler(BAN_PARENT_ACTION_NAME, new Callable<BanParentTaskRequest>() {
        @Override
        public BanParentTaskRequest call() throws Exception {
            return new BanParentTaskRequest();
        }
    }, ThreadPool.Names.SAME, new
        BanParentRequestHandler());
}

开发者ID:baidu，项目名称:Elasticsearch，代码行数:20，代码来源:TransportCancelTasksAction.java

示例6: TransportBroadcastByNodeAction

import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver; //导入依赖的package包/类
public TransportBroadcastByNodeAction(
        Settings settings,
        String actionName,
        ThreadPool threadPool,
        ClusterService clusterService,
        TransportService transportService,
        ActionFilters actionFilters,
        IndexNameExpressionResolver indexNameExpressionResolver,
        Supplier<Request> request,
        String executor,
        boolean canTripCircuitBreaker) {
    super(settings, actionName, canTripCircuitBreaker, threadPool, transportService, actionFilters, indexNameExpressionResolver,
        request);

    this.clusterService = clusterService;
    this.transportService = transportService;

    transportNodeBroadcastAction = actionName + "[n]";

    transportService.registerRequestHandler(transportNodeBroadcastAction, NodeRequest::new, executor, false, canTripCircuitBreaker,
        new BroadcastByNodeTransportRequestHandler());
}

开发者ID:justor，项目名称:elasticsearch_my，代码行数:23，代码来源:TransportBroadcastByNodeAction.java

示例7: TransportTasksAction

import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver; //导入依赖的package包/类
protected TransportTasksAction(Settings settings, String actionName, ClusterName clusterName, ThreadPool threadPool,
                               ClusterService clusterService, TransportService transportService, ActionFilters actionFilters,
                               IndexNameExpressionResolver indexNameExpressionResolver, Callable<TasksRequest> requestFactory,
                               String nodeExecutor) {
    super(settings, actionName, threadPool, transportService, actionFilters, indexNameExpressionResolver, requestFactory);
    this.clusterName = clusterName;
    this.clusterService = clusterService;
    this.transportService = transportService;
    this.transportNodeAction = actionName + "[n]";
    this.requestFactory = requestFactory;

    transportService.registerRequestHandler(transportNodeAction, new Callable<NodeTaskRequest>() {
        @Override
        public NodeTaskRequest call() throws Exception {
            return new NodeTaskRequest();
        }
    }, nodeExecutor, new NodeTransportHandler());
}

开发者ID:baidu，项目名称:Elasticsearch，代码行数:19，代码来源:TransportTasksAction.java

示例8: TransportMultiTermVectorsAction

import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver; //导入依赖的package包/类
@Inject
public TransportMultiTermVectorsAction(Settings settings, ThreadPool threadPool, TransportService transportService,
                                       ClusterService clusterService, TransportShardMultiTermsVectorAction shardAction,
                                       ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver) {
    super(settings, MultiTermVectorsAction.NAME, threadPool, transportService, actionFilters, indexNameExpressionResolver, MultiTermVectorsRequest.class);
    this.clusterService = clusterService;
    this.shardAction = shardAction;
}

开发者ID:baidu，项目名称:Elasticsearch，代码行数:9，代码来源:TransportMultiTermVectorsAction.java

示例9: TransportMultiSearchTemplateAction

import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver; //导入依赖的package包/类
@Inject
public TransportMultiSearchTemplateAction(Settings settings, ThreadPool threadPool, TransportService transportService,
                                          ActionFilters actionFilters, IndexNameExpressionResolver resolver,
                                          TransportSearchTemplateAction searchTemplateAction) {
    super(settings, MultiSearchTemplateAction.NAME, threadPool, transportService, actionFilters, resolver,
            MultiSearchTemplateRequest::new);
    this.searchTemplateAction = searchTemplateAction;
}

开发者ID:justor，项目名称:elasticsearch_my，代码行数:9，代码来源:TransportMultiSearchTemplateAction.java

示例10: TransportUpdateByQueryAction

import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver; //导入依赖的package包/类
@Inject
public TransportUpdateByQueryAction(Settings settings, ThreadPool threadPool, ActionFilters actionFilters,
        IndexNameExpressionResolver indexNameExpressionResolver, Client client, TransportService transportService,
        ScriptService scriptService, ClusterService clusterService) {
    super(settings, UpdateByQueryAction.NAME, threadPool, transportService, actionFilters,
            indexNameExpressionResolver, UpdateByQueryRequest::new);
    this.client = client;
    this.scriptService = scriptService;
    this.clusterService = clusterService;
}

开发者ID:justor，项目名称:elasticsearch_my，代码行数:11，代码来源:TransportUpdateByQueryAction.java

示例11: TransportRethrottleAction

import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver; //导入依赖的package包/类
@Inject
public TransportRethrottleAction(Settings settings, ThreadPool threadPool, ClusterService clusterService,
        TransportService transportService, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver,
        Client client) {
    super(settings, RethrottleAction.NAME, threadPool, clusterService, transportService, actionFilters, indexNameExpressionResolver,
            RethrottleRequest::new, ListTasksResponse::new, ThreadPool.Names.MANAGEMENT);
    this.client = client;
}

开发者ID:justor，项目名称:elasticsearch_my，代码行数:9，代码来源:TransportRethrottleAction.java

示例12: TransportReindexAction

import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver; //导入依赖的package包/类
@Inject
public TransportReindexAction(Settings settings, ThreadPool threadPool, ActionFilters actionFilters,
        IndexNameExpressionResolver indexNameExpressionResolver, ClusterService clusterService, ScriptService scriptService,
        AutoCreateIndex autoCreateIndex, Client client, TransportService transportService) {
    super(settings, ReindexAction.NAME, threadPool, transportService, actionFilters, indexNameExpressionResolver,
            ReindexRequest::new);
    this.clusterService = clusterService;
    this.scriptService = scriptService;
    this.autoCreateIndex = autoCreateIndex;
    this.client = client;
    remoteWhitelist = buildRemoteWhitelist(REMOTE_CLUSTER_WHITELIST.get(settings));
}

开发者ID:justor，项目名称:elasticsearch_my，代码行数:13，代码来源:TransportReindexAction.java

示例13: TransportClusterUpdateSettingsAction

import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver; //导入依赖的package包/类
@Inject
public TransportClusterUpdateSettingsAction(Settings settings, TransportService transportService, ClusterService clusterService, ThreadPool threadPool,
                                            AllocationService allocationService, @ClusterDynamicSettings DynamicSettings dynamicSettings,
                                            ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver) {
    super(settings, ClusterUpdateSettingsAction.NAME, transportService, clusterService, threadPool, actionFilters, indexNameExpressionResolver, ClusterUpdateSettingsRequest.class);
    this.allocationService = allocationService;
    this.dynamicSettings = dynamicSettings;
}

开发者ID:baidu，项目名称:Elasticsearch，代码行数:9，代码来源:TransportClusterUpdateSettingsAction.java

示例14: TransportGetSnapshotsAction

import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver; //导入依赖的package包/类
@Inject
public TransportGetSnapshotsAction(Settings settings, TransportService transportService, ClusterService clusterService,
                                   ThreadPool threadPool, SnapshotsService snapshotsService, ActionFilters actionFilters,
                                   IndexNameExpressionResolver indexNameExpressionResolver) {
    super(settings, GetSnapshotsAction.NAME, transportService, clusterService, threadPool, actionFilters, indexNameExpressionResolver, GetSnapshotsRequest.class);
    this.snapshotsService = snapshotsService;
}

开发者ID:baidu，项目名称:Elasticsearch，代码行数:8，代码来源:TransportGetSnapshotsAction.java

示例15: TransportBulkAction

import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver; //导入依赖的package包/类
@Inject
public TransportBulkAction(Settings settings, ThreadPool threadPool, TransportService transportService, ClusterService clusterService,
                           TransportShardBulkAction shardBulkAction, TransportCreateIndexAction createIndexAction,
                           ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver,
                           AutoCreateIndex autoCreateIndex) {
    super(settings, BulkAction.NAME, threadPool, transportService, actionFilters, indexNameExpressionResolver, BulkRequest.class);
    this.clusterService = clusterService;
    this.shardBulkAction = shardBulkAction;
    this.createIndexAction = createIndexAction;

    this.autoCreateIndex = autoCreateIndex;
    this.allowIdGeneration = this.settings.getAsBoolean("action.bulk.action.allow_id_generation", true);
}

开发者ID:baidu，项目名称:Elasticsearch，代码行数:14，代码来源:TransportBulkAction.java

示例16: TransportShardFlushAction

import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver; //导入依赖的package包/类
@Inject
public TransportShardFlushAction(Settings settings, TransportService transportService, ClusterService clusterService,
                                 IndicesService indicesService, ThreadPool threadPool, ShardStateAction shardStateAction,
                                 MappingUpdatedAction mappingUpdatedAction, ActionFilters actionFilters,
                                 IndexNameExpressionResolver indexNameExpressionResolver) {
    super(settings, NAME, transportService, clusterService, indicesService, threadPool, shardStateAction, mappingUpdatedAction,
            actionFilters, indexNameExpressionResolver, ShardFlushRequest.class, ShardFlushRequest.class, ThreadPool.Names.FLUSH);
}

开发者ID:baidu，项目名称:Elasticsearch，代码行数:9，代码来源:TransportShardFlushAction.java

示例17: TransportShardBulkAction

import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver; //导入依赖的package包/类
@Inject
public TransportShardBulkAction(Settings settings, TransportService transportService, ClusterService clusterService,
                                IndicesService indicesService, ThreadPool threadPool, ShardStateAction shardStateAction,
                                MappingUpdatedAction mappingUpdatedAction, UpdateHelper updateHelper, ActionFilters actionFilters,
                                IndexNameExpressionResolver indexNameExpressionResolver, FsService fsService) {
    super(settings, ACTION_NAME, transportService, clusterService, indicesService, threadPool, shardStateAction, mappingUpdatedAction,
            actionFilters, indexNameExpressionResolver,
            BulkShardRequest.class, BulkShardRequest.class, ThreadPool.Names.BULK);
    this.updateHelper = updateHelper;
    this.allowIdGeneration = settings.getAsBoolean("action.allow_id_generation", true);
    this.fsService = fsService;
}

开发者ID:baidu，项目名称:Elasticsearch，代码行数:13，代码来源:TransportShardBulkAction.java

示例18: TransportClearScrollAction

import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver; //导入依赖的package包/类
@Inject
public TransportClearScrollAction(Settings settings, TransportService transportService, ThreadPool threadPool,
                                  ClusterService clusterService, ActionFilters actionFilters,
                                  IndexNameExpressionResolver indexNameExpressionResolver,
                                  SearchTransportService searchTransportService) {
    super(settings, ClearScrollAction.NAME, threadPool, transportService, actionFilters, indexNameExpressionResolver, ClearScrollRequest::new);
    this.clusterService = clusterService;
    this.searchTransportService = searchTransportService;
}

开发者ID:justor，项目名称:elasticsearch_my，代码行数:10，代码来源:TransportClearScrollAction.java

示例19: GlobalCheckpointSyncAction

import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver; //导入依赖的package包/类
@Inject
public GlobalCheckpointSyncAction(Settings settings, TransportService transportService,
                                  ClusterService clusterService, IndicesService indicesService,
                                  ThreadPool threadPool, ShardStateAction shardStateAction,
                                  ActionFilters actionFilters,
                                  IndexNameExpressionResolver indexNameExpressionResolver) {
    super(settings, ACTION_NAME, transportService, clusterService, indicesService, threadPool, shardStateAction,
        actionFilters, indexNameExpressionResolver, PrimaryRequest::new, ReplicaRequest::new,
        ThreadPool.Names.SAME);
}

开发者ID:justor，项目名称:elasticsearch_my，代码行数:11，代码来源:GlobalCheckpointSyncAction.java

示例20: TransportShardRefreshAction

import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver; //导入依赖的package包/类
@Inject
public TransportShardRefreshAction(Settings settings, TransportService transportService, ClusterService clusterService,
                                   IndicesService indicesService, ThreadPool threadPool, ShardStateAction shardStateAction,
                                   MappingUpdatedAction mappingUpdatedAction, ActionFilters actionFilters,
                                   IndexNameExpressionResolver indexNameExpressionResolver) {
    super(settings, NAME, transportService, clusterService, indicesService, threadPool, shardStateAction, mappingUpdatedAction,
            actionFilters, indexNameExpressionResolver, ReplicationRequest.class, ReplicationRequest.class, ThreadPool.Names.REFRESH);
}

开发者ID:baidu，项目名称:Elasticsearch，代码行数:9，代码来源:TransportShardRefreshAction.java

注：本文中的org.elasticsearch.cluster.metadata.IndexNameExpressionResolver类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。