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

IndicesService.ensureChangesAllowed介绍

[英]Checks if changes (adding / removing) indices, shards and so on are allowed.
[中]检查是否允许更改（添加/删除）索引、碎片等。

代码示例

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

public synchronized IndexService createIndex(
    final IndexMetaData indexMetaData, final List<IndexEventListener> builtInListeners) throws IOException {
  ensureChangesAllowed();
  if (indexMetaData.getIndexUUID().equals(IndexMetaData.INDEX_UUID_NA_VALUE)) {
    throw new IllegalArgumentException("index must have a real UUID found value: [" + indexMetaData.getIndexUUID() + "]");

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

@Override
public IndexShard createShard(ShardRouting shardRouting, RecoveryState recoveryState, PeerRecoveryTargetService recoveryTargetService,
               PeerRecoveryTargetService.RecoveryListener recoveryListener, RepositoriesService repositoriesService,
               Consumer<IndexShard.ShardFailure> onShardFailure,
               Consumer<ShardId> globalCheckpointSyncer) throws IOException {
  ensureChangesAllowed();
  IndexService indexService = indexService(shardRouting.index());
  IndexShard indexShard = indexService.createShard(shardRouting, globalCheckpointSyncer);
  indexShard.addShardFailureCallback(onShardFailure);
  indexShard.startRecovery(recoveryState, recoveryTargetService, recoveryListener, repositoriesService,
    (type, mapping) -> {
      assert recoveryState.getRecoverySource().getType() == RecoverySource.Type.LOCAL_SHARDS:
        "mapping update consumer only required by local shards recovery";
      client.admin().indices().preparePutMapping()
        .setConcreteIndex(shardRouting.index()) // concrete index - no name clash, it uses uuid
        .setType(type)
        .setSource(mapping.source().string(), XContentType.JSON)
        .get();
    }, this);
  return indexShard;
}

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

ensureChangesAllowed();
if (indexMetaData.getIndexUUID().equals(IndexMetaData.INDEX_UUID_NA_VALUE)) {
  throw new IllegalArgumentException("index must have a real UUID found value: [" + indexMetaData.getIndexUUID() + "]");

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

public synchronized IndexService createIndex(
    final IndexMetaData indexMetaData, final List<IndexEventListener> builtInListeners) throws IOException {
  ensureChangesAllowed();
  if (indexMetaData.getIndexUUID().equals(IndexMetaData.INDEX_UUID_NA_VALUE)) {
    throw new IllegalArgumentException("index must have a real UUID found value: [" + indexMetaData.getIndexUUID() + "]");

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

@Override
public IndexShard createShard(ShardRouting shardRouting, RecoveryState recoveryState, PeerRecoveryTargetService recoveryTargetService,
               PeerRecoveryTargetService.RecoveryListener recoveryListener, RepositoriesService repositoriesService,
               Callback<IndexShard.ShardFailure> onShardFailure) throws IOException {
  ensureChangesAllowed();
  IndexService indexService = indexService(shardRouting.index());
  IndexShard indexShard = indexService.createShard(shardRouting);
  indexShard.addShardFailureCallback(onShardFailure);
  indexShard.startRecovery(recoveryState, recoveryTargetService, recoveryListener, repositoriesService,
    (type, mapping) -> {
      assert recoveryState.getRecoverySource().getType() == RecoverySource.Type.LOCAL_SHARDS:
        "mapping update consumer only required by local shards recovery";
      try {
        client.admin().indices().preparePutMapping()
          .setConcreteIndex(shardRouting.index()) // concrete index - no name clash, it uses uuid
          .setType(type)
          .setSource(mapping.source().string())
          .get();
      } catch (IOException ex) {
        throw new ElasticsearchException("failed to stringify mapping source", ex);
      }
    }, this);
  return indexShard;
}

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

@Override
public IndexShard createShard(ShardRouting shardRouting, RecoveryState recoveryState, PeerRecoveryTargetService recoveryTargetService,
               PeerRecoveryTargetService.RecoveryListener recoveryListener, RepositoriesService repositoriesService,
               Consumer<IndexShard.ShardFailure> onShardFailure,
               Consumer<ShardId> globalCheckpointSyncer) throws IOException {
  ensureChangesAllowed();
  IndexService indexService = indexService(shardRouting.index());
  IndexShard indexShard = indexService.createShard(shardRouting, globalCheckpointSyncer);
  indexShard.addShardFailureCallback(onShardFailure);
  indexShard.startRecovery(recoveryState, recoveryTargetService, recoveryListener, repositoriesService,
    (type, mapping) -> {
      assert recoveryState.getRecoverySource().getType() == RecoverySource.Type.LOCAL_SHARDS:
        "mapping update consumer only required by local shards recovery";
      try {
        client.admin().indices().preparePutMapping()
          .setConcreteIndex(shardRouting.index()) // concrete index - no name clash, it uses uuid
          .setType(type)
          .setSource(mapping.source().string(), XContentType.JSON)
          .get();
      } catch (IOException ex) {
        throw new ElasticsearchException("failed to stringify mapping source", ex);
      }
    }, this);
  return indexShard;
}