import org.elasticsearch.action.admin.indices.status.IndicesStatusResponse; //导入依赖的package包/类
@Override
public synchronized Matrix get(int index) {
	IndicesStatusResponse response = client.admin().indices().prepareStatus().execute().actionGet();
	Set<String> indexSet = new TreeSet<String>(response.getIndices().keySet());
	List<String> indexList = new ArrayList<String>(indexSet);
	return Matrix.Factory.linkToValue(indexList.get(index));
}
 

import org.elasticsearch.action.admin.indices.status.IndicesStatusResponse; //导入依赖的package包/类
public IndexStatus[] getIndexStatus() {
  String[] indices = this.getClusterState().metaData().getConcreteAllIndices();
  IndicesStatusRequestBuilder builder = client.admin().indices().prepareStatus(indices);
  IndicesStatusResponse response = builder.execute().actionGet();
  Map<String, IndexStatus> map = response.getIndices();
  return map.values().toArray(new IndexStatus[map.size()]);
}
 

import org.elasticsearch.action.admin.indices.status.IndicesStatusResponse; //导入依赖的package包/类
@Override
public void run() {
    log.info("I am going to do some clean up for index window: " + window);
    final IndicesStatusResponse indicesStatusResponse = client.admin()
            .indices().prepareStatus().execute().actionGet();
    final Set<String> allIndices = indicesStatusResponse.getIndices()
            .keySet();
    final Set<String> toBeRemoved = getToBeRemovedIndices(allIndices);
    if (toBeRemoved.isEmpty()) {
        log.info("All good... no index to be removed.");
        return;
    }
    for (final String index : toBeRemoved) {
        log.info("This index is going to be removed: " + index);
        try {
            final DeleteIndexResponse deleteResponse = client.admin()
                    .indices().delete(new DeleteIndexRequest(index))
                    .actionGet();
            if (deleteResponse.isAcknowledged()) {
                log.info("Delete successful for: " + index);
            } else {
                log.info("Delete not successful for: " + index);
            }
        } catch (final Exception e) {
            log.error("Something went wrong while deleting index " + index,
                    e);
        }
    }
}
 

import org.elasticsearch.action.admin.indices.status.IndicesStatusResponse; //导入依赖的package包/类
public static void clearIndices(Client esClient) {
    IndicesStatusRequest req = Requests.indicesStatusRequest((String[]) null);
    IndicesStatusResponse statuses = indicesAdmin(esClient).status(req).actionGet();
    for (String index : statuses.getIndices().keySet()) {
        indicesAdmin(esClient).delete(Requests.deleteIndexRequest(index)).actionGet();
    }
}
 

import org.elasticsearch.action.admin.indices.status.IndicesStatusResponse; //导入依赖的package包/类
@Override
protected XContentBuilder toXContent(IndicesStatusRequest request, IndicesStatusResponse response, XContentBuilder builder) throws IOException {
    builder.startObject();
    builder.field(Fields.OK, true);
    buildBroadcastShardsHeader(builder, response);
    response.toXContent(builder, ToXContent.EMPTY_PARAMS);
    builder.endObject();
    return builder;
}
 

import org.elasticsearch.action.admin.indices.status.IndicesStatusResponse; //导入依赖的package包/类
@Override
public synchronized int size() {
	IndicesStatusResponse response = client.admin().indices().prepareStatus().execute().actionGet();
	return response.getIndices().size();
}
 

import org.elasticsearch.action.admin.indices.status.IndicesStatusResponse; //导入依赖的package包/类
@Override
protected ActionFuture<IndicesStatusResponse> doExecute(IndicesStatusRequest request) {
    return client.admin().indices().status(request);
}