本文整理了Java中org.elasticsearch.common.inject.Inject.<init>()方法的一些代码示例，展示了Inject.<init>()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Inject.<init>()方法的具体详情如下：
包路径：org.elasticsearch.common.inject.Inject
类名称：Inject
方法名：<init>

Inject.<init>介绍

暂无

代码示例

代码示例来源：origin: floragunncom/search-guard

@Inject
public TransportWhoAmIAction(final Settings settings,
    final ThreadPool threadPool, final ClusterService clusterService, final TransportService transportService,
    final AdminDNs adminDNs, final ActionFilters actionFilters, final IndexNameExpressionResolver indexNameExpressionResolver) {
  super(settings, WhoAmIAction.NAME, threadPool, transportService, actionFilters, indexNameExpressionResolver, WhoAmIRequest::new);
  this.adminDNs = adminDNs;
}

代码示例来源：origin: floragunncom/search-guard

@Inject
public TransportConfigUpdateAction(final Settings settings,
    final ThreadPool threadPool, final ClusterService clusterService, final TransportService transportService,
    final IndexBaseConfigurationRepository configurationRepository, final ActionFilters actionFilters, final IndexNameExpressionResolver indexNameExpressionResolver,
    Provider<BackendRegistry> backendRegistry) {
  
  super(settings, ConfigUpdateAction.NAME, threadPool, clusterService, transportService, actionFilters,
      indexNameExpressionResolver, ConfigUpdateRequest::new, TransportConfigUpdateAction.NodeConfigUpdateRequest::new,
      ThreadPool.Names.MANAGEMENT, ConfigUpdateNodeResponse.class);
  this.configurationRepository = configurationRepository;
  this.backendRegistry = backendRegistry;
}

代码示例来源：origin: floragunncom/search-guard

@Inject
public TransportLicenseInfoAction(final Settings settings,
    final ThreadPool threadPool, final ClusterService clusterService, final TransportService transportService,
    final IndexBaseConfigurationRepository configurationRepository, final ActionFilters actionFilters, final IndexNameExpressionResolver indexNameExpressionResolver) {
  
  super(settings, LicenseInfoAction.NAME, threadPool, clusterService, transportService, actionFilters,
      indexNameExpressionResolver, LicenseInfoRequest::new, TransportLicenseInfoAction.NodeLicenseRequest::new,
      ThreadPool.Names.MANAGEMENT, LicenseInfoNodeResponse.class);
  this.configurationRepository = configurationRepository;
}

代码示例来源：origin: richardwilly98/elasticsearch-river-mongodb

@Inject
public MongoClientService(Settings settings) {
  super(settings);
}

代码示例来源：origin: floragunncom/search-guard

@Inject
public GuiceHolder(final RepositoriesService repositoriesService,
    final TransportService remoteClusterService) {
  GuiceHolder.repositoriesService = repositoriesService;
  GuiceHolder.remoteClusterService = remoteClusterService.getRemoteClusterService();
}

代码示例来源：origin: floragunncom/search-guard

@Inject
public PrivilegesInterceptorImpl(IndexNameExpressionResolver resolver, ClusterService clusterService, Client client, ThreadPool threadPool) {
  super(resolver, clusterService, client, threadPool);
}

代码示例来源：origin: medcl/elasticsearch-analysis-ik

@Inject
public Configuration(Environment env,Settings settings) {
  this.environment = env;
  this.settings=settings;
  this.useSmart = settings.get("use_smart", "false").equals("true");
  this.enableLowercase = settings.get("enable_lowercase", "true").equals("true");
  this.enableRemoteDict = settings.get("enable_remote_dict", "true").equals("true");
  Dictionary.initial(this);
}

代码示例来源：origin: medcl/elasticsearch-analysis-pinyin

@Inject
public PinyinAnalyzerProvider(IndexSettings indexSettings, Environment env, String name, Settings settings) {
  super(indexSettings, name, settings);
  config=new PinyinConfig(settings);
  analyzer = new PinyinAnalyzer(config);
}

代码示例来源：origin: richardwilly98/elasticsearch-river-mongodb

@Inject
public RestMongoDBRiverAction(Settings settings, Client esClient, RestController controller, @RiverIndexName String riverIndexName) {
  super(settings, controller, esClient);
  this.riverIndexName = riverIndexName;
  String baseUrl = "/" + riverIndexName + "/" + MongoDBRiver.TYPE;
  logger.trace("RestMongoDBRiverAction - baseUrl: {}", baseUrl);
  controller.registerHandler(RestRequest.Method.GET, baseUrl + "/{action}", this);
  controller.registerHandler(RestRequest.Method.POST, baseUrl + "/{river}/{action}", this);
}

代码示例来源：origin: richardwilly98/elasticsearch-river-mongodb

@Inject
public MongoDBRiver(RiverName riverName, RiverSettings settings, @RiverIndexName String riverIndexName,
    Client esClient, ScriptService scriptService, MongoClientService mongoClientService) {
  super(riverName, settings);
  if (logger.isTraceEnabled()) {
    logger.trace("Initializing");
  }
  this.esClient = esClient;
  this.scriptService = scriptService;
  this.mongoClientService = mongoClientService;
  this.definition = MongoDBRiverDefinition.parseSettings(riverName.name(), riverIndexName, settings, scriptService);
  BlockingQueue<QueueEntry> stream = definition.getThrottleSize() == -1 ? new LinkedTransferQueue<QueueEntry>()
      : new ArrayBlockingQueue<QueueEntry>(definition.getThrottleSize());
  this.context = new SharedContext(stream, Status.STOPPED);
}

代码示例来源：origin: org.elasticsearch/elasticsearch

@Inject
public MetaDataUpdateSettingsService(ClusterService clusterService, AllocationService allocationService,
                   IndexScopedSettings indexScopedSettings, IndicesService indicesService, ThreadPool threadPool) {
  this.clusterService = clusterService;
  this.threadPool = threadPool;
  this.allocationService = allocationService;
  this.indexScopedSettings = indexScopedSettings;
  this.indicesService = indicesService;
}

代码示例来源：origin: org.elasticsearch/elasticsearch

@Inject
public RoutingService(Settings settings, ClusterService clusterService, AllocationService allocationService) {
  super(settings);
  this.clusterService = clusterService;
  this.allocationService = allocationService;
}

代码示例来源：origin: org.elasticsearch/elasticsearch

@Inject
public MetaDataDeleteIndexService(Settings settings, ClusterService clusterService, AllocationService allocationService) {
  this.settings = settings;
  this.clusterService = clusterService;
  this.allocationService = allocationService;
}

代码示例来源：origin: org.elasticsearch/elasticsearch

@Inject
public TransportDeleteRepositoryAction(Settings settings, TransportService transportService, ClusterService clusterService,
                    RepositoriesService repositoriesService, ThreadPool threadPool, ActionFilters actionFilters,
                    IndexNameExpressionResolver indexNameExpressionResolver) {
  super(settings, DeleteRepositoryAction.NAME, transportService, clusterService, threadPool, actionFilters,
     indexNameExpressionResolver, DeleteRepositoryRequest::new);
  this.repositoriesService = repositoriesService;
}

代码示例来源：origin: org.elasticsearch/elasticsearch

@Inject
public TransportClusterHealthAction(Settings settings, TransportService transportService, ClusterService clusterService,
                  ThreadPool threadPool, ActionFilters actionFilters,
                  IndexNameExpressionResolver indexNameExpressionResolver, GatewayAllocator gatewayAllocator) {
  super(settings, ClusterHealthAction.NAME, false, transportService, clusterService, threadPool, actionFilters,
    indexNameExpressionResolver, ClusterHealthRequest::new);
  this.gatewayAllocator = gatewayAllocator;
}

代码示例来源：origin: org.elasticsearch/elasticsearch

@Inject
public MetaDataIndexTemplateService(ClusterService clusterService,
                  MetaDataCreateIndexService metaDataCreateIndexService,
                  AliasValidator aliasValidator, IndicesService indicesService,
                  IndexScopedSettings indexScopedSettings, NamedXContentRegistry xContentRegistry) {
  this.clusterService = clusterService;
  this.aliasValidator = aliasValidator;
  this.indicesService = indicesService;
  this.metaDataCreateIndexService = metaDataCreateIndexService;
  this.indexScopedSettings = indexScopedSettings;
  this.xContentRegistry = xContentRegistry;
}

代码示例来源：origin: org.elasticsearch/elasticsearch

@Inject
public TransportRemoteInfoAction(Settings settings, ThreadPool threadPool, TransportService transportService,
                 ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver,
                 SearchTransportService searchTransportService) {
  super(settings, RemoteInfoAction.NAME, threadPool, transportService, actionFilters, indexNameExpressionResolver,
    RemoteInfoRequest::new);
  this.remoteClusterService = searchTransportService.getRemoteClusterService();
}

代码示例来源：origin: org.elasticsearch/elasticsearch

@Inject
public SnapshotsService(Settings settings, ClusterService clusterService, IndexNameExpressionResolver indexNameExpressionResolver, RepositoriesService repositoriesService, ThreadPool threadPool) {
  super(settings);
  this.clusterService = clusterService;
  this.indexNameExpressionResolver = indexNameExpressionResolver;
  this.repositoriesService = repositoriesService;
  this.threadPool = threadPool;
  if (DiscoveryNode.isMasterNode(settings)) {
    // addLowPriorityApplier to make sure that Repository will be created before snapshot
    clusterService.addLowPriorityApplier(this);
  }
}

代码示例来源：origin: org.elasticsearch/elasticsearch

@Inject
public TransportCancelTasksAction(Settings settings, ThreadPool threadPool, ClusterService clusterService,
                 TransportService transportService, ActionFilters actionFilters,
                 IndexNameExpressionResolver indexNameExpressionResolver) {
  super(settings, CancelTasksAction.NAME, threadPool, clusterService, transportService, actionFilters,
    indexNameExpressionResolver, CancelTasksRequest::new, CancelTasksResponse::new, ThreadPool.Names.MANAGEMENT);
  transportService.registerRequestHandler(BAN_PARENT_ACTION_NAME, ThreadPool.Names.SAME, BanParentTaskRequest::new,
    new BanParentRequestHandler());
}

代码示例来源：origin: org.elasticsearch/elasticsearch

@Inject
public BalancedShardsAllocator(Settings settings, ClusterSettings clusterSettings) {
  setWeightFunction(INDEX_BALANCE_FACTOR_SETTING.get(settings), SHARD_BALANCE_FACTOR_SETTING.get(settings));
  setThreshold(THRESHOLD_SETTING.get(settings));
  clusterSettings.addSettingsUpdateConsumer(INDEX_BALANCE_FACTOR_SETTING, SHARD_BALANCE_FACTOR_SETTING, this::setWeightFunction);
  clusterSettings.addSettingsUpdateConsumer(THRESHOLD_SETTING, this::setThreshold);
}