AsyncCallQueries.java

public static List<Entity> asyncQuery(List<Query> queries, FetchOptions fetchOptions)
		throws InterruptedException, ExecutionException {
	@SuppressWarnings("unchecked")
	Delegate<Environment> delegate = ApiProxy.getDelegate();
	Environment env = ApiProxy.getCurrentEnvironment();
	ApiConfig config = new ApiProxy.ApiConfig();
	config.setDeadlineInSeconds(5.0);

	List<Future<byte[]>> futures = new ArrayList<Future<byte[]>>(queries.size());
	for (Query query : queries) {
		futures.add(delegate.makeAsyncCall(env, "datastore_v3", "RunQuery", PbUtil
			.toQueryRequestPb(query, fetchOptions).toByteArray(), config));
	}
	List<List<Entity>> lists = new ArrayList<List<Entity>>();
	for (Future<byte[]> future : futures) {
		DatastorePb.QueryResult rPb = new DatastorePb.QueryResult();
		rPb.mergeFrom(future.get());
		Iterator<EntityProto> it = rPb.resultIterator();
		List<Entity> entities = new ArrayList<Entity>();
		while (it.hasNext()) {
			entities.add(EntityTranslator.createFromPb(it.next()));
		}
		lists.add(entities);
	}
	Map<Key, Entity> map = new HashMap<Key, Entity>();
	for (List<Entity> list : lists) {
		for (Entity entity : list) {
			if (map.containsKey(entity.getKey()) == false) {
				map.put(entity.getKey(), entity);
			}
		}
	}
	return new ArrayList<Entity>(map.values());
}