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

ClusterState.blocks介绍

暂无

代码示例

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

/**
 * Returns <code>true</code> iff the cluster level blocks have changed between cluster states.
 * Note that this is an object reference equality test, not an equals test.
 */
public boolean blocksChanged() {
  return state.blocks() != previousState.blocks();
}

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

@Override
protected ClusterBlockException checkBlock(DeleteSnapshotRequest request, ClusterState state) {
  // Cluster is not affected but we look up repositories in metadata
  return state.blocks().globalBlockedException(ClusterBlockLevel.METADATA_READ);
}

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

@Override
  protected ClusterBlockException checkRequestBlock(ClusterState state, ClearIndicesCacheRequest request, String[] concreteIndices) {
    return state.blocks().indicesBlockedException(ClusterBlockLevel.METADATA_WRITE, concreteIndices);
  }
}

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

@Override
protected ClusterBlockException checkBlock(Request request, ClusterState state) {
  // Cluster is not affected but we look up repositories in metadata
  return state.blocks().globalBlockedException(ClusterBlockLevel.METADATA_WRITE);
}

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

@Override
  protected ClusterBlockException checkRequestBlock(ClusterState state, RecoveryRequest request, String[] concreteIndices) {
    return state.blocks().indicesBlockedException(ClusterBlockLevel.READ, concreteIndices);
  }
}

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

@Override
protected ClusterBlockException checkBlock(CreateSnapshotRequest request, ClusterState state) {
  // We are reading the cluster metadata and indices - so we need to check both blocks
  ClusterBlockException clusterBlockException = state.blocks().globalBlockedException(ClusterBlockLevel.METADATA_READ);
  if (clusterBlockException != null) {
    return clusterBlockException;
  }
  return state.blocks()
    .indicesBlockedException(ClusterBlockLevel.READ, indexNameExpressionResolver.concreteIndexNames(state, request));
}

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

@Override
protected ClusterBlockException checkBlock(IndicesAliasesRequest request, ClusterState state) {
  Set<String> indices = new HashSet<>();
  for (AliasActions aliasAction : request.aliasActions()) {
    Collections.addAll(indices, aliasAction.indices());
  }
  return state.blocks().indicesBlockedException(ClusterBlockLevel.METADATA_WRITE, indices.toArray(new String[indices.size()]));
}

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

@Override
protected ClusterBlockException checkBlock(IndicesShardStoresRequest request, ClusterState state) {
  return state.blocks().indicesBlockedException(ClusterBlockLevel.METADATA_READ,
    indexNameExpressionResolver.concreteIndexNames(state, request));
}

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

@Override
protected ClusterBlockException checkBlock(CloseIndexRequest request, ClusterState state) {
  return state.blocks().indicesBlockedException(ClusterBlockLevel.METADATA_WRITE,
    indexNameExpressionResolver.concreteIndexNames(state, request));
}

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

@Override
protected ClusterBlockException checkBlock(TypesExistsRequest request, ClusterState state) {
  return state.blocks().indicesBlockedException(ClusterBlockLevel.METADATA_READ,
    indexNameExpressionResolver.concreteIndexNames(state, request));
}

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

@Override
  protected ClusterBlockException checkRequestBlock(ClusterState state, InternalRequest request) {
    return state.blocks().indexBlockedException(ClusterBlockLevel.METADATA_READ, request.concreteIndex());
  }
}

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

@Override
protected ClusterBlockException checkBlock(GetSettingsRequest request, ClusterState state) {
  return state.blocks().indicesBlockedException(ClusterBlockLevel.METADATA_READ,
    indexNameExpressionResolver.concreteIndexNames(state, request));
}

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

@Override
protected ClusterBlockException checkBlock(GetAliasesRequest request, ClusterState state) {
  return state.blocks().indicesBlockedException(ClusterBlockLevel.METADATA_READ,
    indexNameExpressionResolver.concreteIndexNames(state, request));
}

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

@Override
protected ClusterBlockException checkBlock(OpenIndexRequest request, ClusterState state) {
  return state.blocks().indicesBlockedException(ClusterBlockLevel.METADATA_WRITE,
    indexNameExpressionResolver.concreteIndexNames(state, request));
}

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

@Override
protected ClusterBlockException checkBlock(GetIndexRequest request, ClusterState state) {
  return state.blocks().indicesBlockedException(ClusterBlockLevel.METADATA_READ,
      indexNameExpressionResolver.concreteIndexNames(state, request));
}

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

@Override
protected ClusterBlockException checkBlock(ClusterSearchShardsRequest request, ClusterState state) {
  return state.blocks().indicesBlockedException(ClusterBlockLevel.METADATA_READ,
      indexNameExpressionResolver.concreteIndexNames(state, request));
}

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

public PingResponse(DiscoveryNode node, DiscoveryNode master, ClusterState state) {
  this(node, master, state.getClusterName(),
    state.blocks().hasGlobalBlock(STATE_NOT_RECOVERED_BLOCK) ?
      ElectMasterService.MasterCandidate.UNRECOVERED_CLUSTER_VERSION : state.version());
}

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

private Map<String, AliasFilter> buildPerIndexAliasFilter(SearchRequest request, ClusterState clusterState,
                             Index[] concreteIndices, Map<String, AliasFilter> remoteAliasMap) {
  final Map<String, AliasFilter> aliasFilterMap = new HashMap<>();
  for (Index index : concreteIndices) {
    clusterState.blocks().indexBlockedRaiseException(ClusterBlockLevel.READ, index.getName());
    AliasFilter aliasFilter = searchService.buildAliasFilter(clusterState, index.getName(), request.indices());
    assert aliasFilter != null;
    aliasFilterMap.put(index.getUUID(), aliasFilter);
  }
  aliasFilterMap.putAll(remoteAliasMap);
  return aliasFilterMap;
}

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

@Override
protected ClusterBlockException checkBlock(PutMappingRequest request, ClusterState state) {
  String[] indices;
  if (request.getConcreteIndex() == null) {
    indices = indexNameExpressionResolver.concreteIndexNames(state, request);
  } else {
    indices = new String[] {request.getConcreteIndex().getName()};
  }
  return state.blocks().indicesBlockedException(ClusterBlockLevel.METADATA_WRITE, indices);
}

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

@Override
protected ClusterBlockException checkBlock(RolloverRequest request, ClusterState state) {
  IndicesOptions indicesOptions = IndicesOptions.fromOptions(true, true,
    request.indicesOptions().expandWildcardsOpen(), request.indicesOptions().expandWildcardsClosed());
  return state.blocks().indicesBlockedException(ClusterBlockLevel.METADATA_WRITE,
    indexNameExpressionResolver.concreteIndexNames(state, indicesOptions, request.indices()));
}