import com.carrotsearch.hppc.ObjectLookupContainer; //导入依赖的package包/类
public static Map<String, List<String>> getIndexTypeMapping() {
	Map<String, List<String>> indexTypeMapping = new HashMap<String, List<String>>();
	List<String> typeList = null;

	ImmutableOpenMap<String, ImmutableOpenMap<String, MappingMetaData>> f = ESReport.getESClient().admin().indices().getMappings(new GetMappingsRequest()).actionGet().getMappings();

	Object[] indexList = f.keys().toArray();
	for (Object indexObj : indexList) {
		String index = indexObj.toString();
		ImmutableOpenMap<String, MappingMetaData> mapping = f.get(index);
		typeList = new ArrayList<String>();
		
		ClusterStateResponse resp = ESReport.getESClient().admin().cluster().prepareState().execute().actionGet();
		ObjectLookupContainer<String> objectLookupContainer = resp.getState().metaData().index(index).getMappings().keys();
		for(ObjectCursor<String> objectCursor:objectLookupContainer){
			typeList.add(objectCursor.value);
		}
		indexTypeMapping.put(index, typeList);
	}
	return indexTypeMapping;
}
 

import com.carrotsearch.hppc.ObjectLookupContainer; //导入依赖的package包/类
@Nonnull
@Override
public Set<String> getClusterIndices() {
    final ObjectLookupContainer<String> indices = esClient.admin().cluster().prepareState()
            .execute().actionGet().getState().getMetaData().indices().keys();
    final Set<String> indicesNames = new HashSet<>();
    for (final Object index : indices.toArray()) {
        indicesNames.add(index.toString());
    }
    return indicesNames;
}
 

import com.carrotsearch.hppc.ObjectLookupContainer; //导入依赖的package包/类
public static List<String> getTypeListFromIndex(String index) {
	List<String> typeList = new ArrayList<String>();
	ClusterStateResponse resp = ESReport.getESClient().admin().cluster().prepareState().execute().actionGet();
	ObjectLookupContainer<String> objectLookupContainer = resp.getState().metaData().index(index).getMappings().keys();
	for(ObjectCursor<String> objectCursor:objectLookupContainer)
	{
		typeList.add(objectCursor.value);
	}
	return typeList;
}
 

import com.carrotsearch.hppc.ObjectLookupContainer; //导入依赖的package包/类
public void deleteOldLogs() throws ConnectionException {
	if(LOGGER.isDebugEnabled()) {
		LOGGER.debug("Deleting old logs...");
	}
	
	List<String> indicesToKeep = createIndicesToKeep();
	
	ObjectLookupContainer<String> indizes = client.admin().cluster().state(new ClusterStateRequest()).actionGet().getState().getMetaData().getIndices().keys();
	Iterator<ObjectCursor<String>> iter = indizes.iterator();
	
	if(LOGGER.isDebugEnabled()) {
		LOGGER.debug("Found " + indizes.size() + " indices.");
	}
	
	while(iter.hasNext()) {
		ObjectCursor<String> cursor = iter.next();
		
		if(!indicesToKeep.contains(cursor.value)) {
			DeleteIndexResponse delete = client.admin().indices().delete(new DeleteIndexRequest(cursor.value)).actionGet();
			if (!delete.isAcknowledged()) {
				LOGGER.warn("Could not delete index " + cursor.value);
			}
		}
	}
	
	if(LOGGER.isDebugEnabled()) {
		LOGGER.debug("Old logs deleted.");
	}
}
 

import com.carrotsearch.hppc.ObjectLookupContainer; //导入依赖的package包/类
@Override
protected SimpleTableDef[] detectSchema() {
    logger.info("Detecting schema for index '{}'", indexName);

    final ClusterStateRequestBuilder clusterStateRequestBuilder = getElasticSearchClient().admin().cluster()
            .prepareState().setIndices(indexName);
    final ClusterState cs = clusterStateRequestBuilder.execute().actionGet().getState();
    
    final List<SimpleTableDef> result = new ArrayList<>();

    final IndexMetaData imd = cs.getMetaData().index(indexName);
    if (imd == null) {
        // index does not exist
        logger.warn("No metadata returned for index name '{}' - no tables will be detected.");
    } else {
        final ImmutableOpenMap<String, MappingMetaData> mappings = imd.getMappings();
        final ObjectLookupContainer<String> documentTypes = mappings.keys();
        for (final ObjectCursor<?> documentTypeCursor : documentTypes) {
            final String documentType = documentTypeCursor.value.toString();
            try {
                final SimpleTableDef table = detectTable(cs, indexName, documentType);
                result.add(table);
            } catch (Exception e) {
                logger.error("Unexpected error during detectTable for document type '{}'", documentType, e);
            }
        }
    }
    return sortTables(result);
}
 

import com.carrotsearch.hppc.ObjectLookupContainer; //导入依赖的package包/类
/**
 * @return an intersection view over the two specified containers (which can be KeyContainer or ObjectHashSet).
 */
// Hppc has forEach, but this means we need to build an intermediate set, with this method we just iterate
// over each unique value without creating a third set.
public static <T> Iterable<T> intersection(ObjectLookupContainer<T> container1, final ObjectLookupContainer<T> container2) {
    assert container1 != null && container2 != null;
    final Iterator<ObjectCursor<T>> iterator = container1.iterator();
    final Iterator<T> intersection = new Iterator<T>() {

        T current;

        @Override
        public boolean hasNext() {
            if (iterator.hasNext()) {
                do {
                    T next = iterator.next().value;
                    if (container2.contains(next)) {
                        current = next;
                        return true;
                    }
                } while (iterator.hasNext());
            }
            return false;
        }

        @Override
        public T next() {
            return current;
        }

        @Override
        public void remove() {
            throw new UnsupportedOperationException();
        }
    };
    return new Iterable<T>() {
        @Override
        public Iterator<T> iterator() {
            return intersection;
        }
    };
}
 

import com.carrotsearch.hppc.ObjectLookupContainer; //导入依赖的package包/类
/**
 * Returns a specialized view of the keys of this associated container.
 * The view additionally implements {@link ObjectLookupContainer}.
 */
public ObjectLookupContainer<KType> keys() {
    return map.keys();
}