Java CloseableIterator类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中com.mysema.commons.lang.CloseableIterator类的典型用法代码示例。如果您正苦于以下问题：Java CloseableIterator类的具体用法？Java CloseableIterator怎么用？Java CloseableIterator使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

CloseableIterator类属于com.mysema.commons.lang包，在下文中一共展示了CloseableIterator类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: createSetFromTuples

import com.mysema.commons.lang.CloseableIterator; //导入依赖的package包/类
public static <T extends Entity> EntitySet<T> createSetFromTuples(entityFromTupleFactory<T> factory, CloseableIterator<Tuple> tuples, Query query, long maxDataSize) {
    EntitySet<T> entitySet = new EntitySetImpl<>(factory.getEntityType());
    int count = 0;
    DataSize size = new DataSize();
    int top = query.getTopOrDefault();
    while (tuples.hasNext()) {
        Tuple tuple = tuples.next();
        entitySet.add(factory.create(tuple, query, size));
        count++;
        if (count >= top) {
            return entitySet;
        }
        if (size.getDataSize() > maxDataSize) {
            LOGGER.debug("Size limit reached: {} > {}.", size.getDataSize(), maxDataSize);
            return entitySet;
        }
    }
    return entitySet;
}

开发者ID:FraunhoferIOSB，项目名称:SensorThingsServer，代码行数:20，代码来源:PropertyHelper.java

示例2: iterate

import com.mysema.commons.lang.CloseableIterator; //导入依赖的package包/类
@Override
public CloseableIterator<Q> iterate() {
    final Iterator<? extends Q> iterator = query().iterator();
    return new CloseableIterator<Q>() {
        @Override
        public boolean hasNext() {
            return iterator.hasNext();
        }

        @Override
        public Q next() {
            return iterator.next();
        }

        @Override
        public void remove() {
            iterator.remove();
        }

        @Override
        public void close() {
        }
    };
}

开发者ID:querydsl，项目名称:querydsl-contrib，代码行数:25，代码来源:DynamoDBQuery.java

示例3: findUtilizationsWithResolution

import com.mysema.commons.lang.CloseableIterator; //导入依赖的package包/类
@Transactional(readOnly = true, isolation = READ_COMMITTED, propagation = MANDATORY)
@Override
public List<Utilization> findUtilizationsWithResolution(UtilizationKey utilizationKey, DateTime start, DateTime end, Minutes resolution) {
    ArrayList<Utilization> results = new ArrayList<>();
    Optional<Utilization> first = findUtilizationAtInstant(utilizationKey, start);
    try (CloseableIterator<Utilization> rest = findUtilizationsBetween(utilizationKey, start, end)) {
        LinkedList<Utilization> utilizations = Stream.concat(
                StreamUtil.asStream(first),
                StreamUtil.asStream(rest))
                .collect(Collectors.toCollection(LinkedList::new));

        Utilization current = null;
        for (DateTime instant = start; !instant.isAfter(end); instant = instant.plus(resolution)) {
            while (!utilizations.isEmpty() && !utilizations.getFirst().timestamp.isAfter(instant)) {
                current = utilizations.removeFirst();
            }
            if (current != null) {
                current.timestamp = instant;
                results.add(current.copy());
            }
        }
    }
    return results;
}

开发者ID:HSLdevcom，项目名称:parkandrideAPI，代码行数:25，代码来源:UtilizationDao.java

示例4: sparqlFind

import com.mysema.commons.lang.CloseableIterator; //导入依赖的package包/类
protected <T extends BaseNode> List<T> sparqlFind(String qry, String idVar, Class<T> c, boolean first) {
    CloseableIterator<Map<String,NODE>> res = _sparql(qry);
    ArrayList<T> result = new ArrayList<T>();
    while (res.hasNext()) {
        for (Map.Entry<String, NODE> n : res.next().entrySet()) {
            if (n.getKey().equals(idVar.replace("?",""))) {
                if (n.getValue().isResource()) {
		result.add(_getById(n.getValue().asResource(), c));
		if (first) 
			return result;
		 else 
			break;
                }
            }
        }
    }
    return result;
}

开发者ID:meshnetinc，项目名称:gmantic，代码行数:19，代码来源:Ontology.java

示例5: sparql

import com.mysema.commons.lang.CloseableIterator; //导入依赖的package包/类
private CloseableIterator<Map<String,NODE>> sparql(String q, QueryLanguage queryType, org.openrdf.query.QueryLanguage language) {
    String f = "prefix :    <" + NS + "> \n";
    f += "prefix rdf:  <http://www.w3.org/1999/02/22-rdf-syntax-ns#> \n";
    f += "prefix rdfs: <http://www.w3.org/2000/01/rdf-schema#> \n";
    f += "prefix owl: <http://www.w3.org/2002/07/owl#> \n";
    f += "prefix fts: <http://rdf.useekm.com/fts#> \n";
    f += q;
    if (sparqlVerbose) logger.info(f);
    RDFConnection conn = connection;
    CloseableIterator<Map<String,NODE>> rows = null;
    try {
       rows = smr.openConnection().createQuery(QueryLanguage.SPARQL, f).getTuples();
   } catch (Exception e) {
        logger.error(e.getMessage());
        for (StackTraceElement ste : e.getStackTrace()) logger.info(ste.toString());
   }
    return rows;
}

开发者ID:meshnetinc，项目名称:gmantic，代码行数:19，代码来源:Ontology.java

示例6: selectAll

import com.mysema.commons.lang.CloseableIterator; //导入依赖的package包/类
public static ArrayList<NODE> selectAll(String q) {
    ArrayList results = new ArrayList<NODE>();
    CloseableIterator cl = sparql(q);
    while(cl.hasNext()){
        Map m = (Map)cl.next();


        Object[] objectArray = m.values().toArray();
        UID[] n = new UID[objectArray.length];
       for(int i = 0; i< objectArray.length; i++){
           n[i] = (UID) objectArray[i];
       }
        results.add(getById(n[0]));

    }
    return results;
}

开发者ID:meshnetinc，项目名称:gmantic，代码行数:18，代码来源:Ontology.java

示例7: testCustomTransform

import com.mysema.commons.lang.CloseableIterator; //导入依赖的package包/类
@Test
@Transactional
public void testCustomTransform() throws Exception {
	JPAQuery query = new JPAQuery(em);
	QStockKeepingUnit path = QStockKeepingUnit.stockKeepingUnit;

	List<SkuDto> results = query.from(path)
			.transform(new ResultTransformer<List<SkuDto>>() {

				@Override
				public List<SkuDto> transform(Projectable arg0) {
					List<SkuDto> result = new ArrayList<SkuDto>();
					CloseableIterator<StockKeepingUnit> iterator = arg0.iterate(QStockKeepingUnit.stockKeepingUnit);
					while (iterator.hasNext()) {
						StockKeepingUnit sku = iterator.next();
						SkuDto dto = new SkuDto(sku.getSkuId(), sku.getName(), sku.getPrice());
						result.add(dto);
					}
					return result;
				}
			});

	Assert.assertEquals(Integer.valueOf(8), Integer.valueOf(results.size()));

}

开发者ID:patrickvankann，项目名称:bjug-querydsl，代码行数:26，代码来源:JpaQueryTest.java

示例8: _04Fields

import com.mysema.commons.lang.CloseableIterator; //导入依赖的package包/类
@Benchmark
public void _04Fields(LimitParam limit, final Blackhole blackhole, ConnectionParam connectionParam) throws Exception {
	SQLQuery query = new SQLQuery(connectionParam.connection, templates);

	CloseableIterator<MappedObject4> iterate = query.from(QTestSmallBenchmarkObject.testSmallBenchmarkObject)
			.limit(limit.limit)
			.iterate(MAPPED_OBJECT_4_Q_BEAN);

	while(iterate.hasNext()) {
		blackhole.consume(iterate.next());
	}
}

开发者ID:arnaudroger，项目名称:mapping-benchmark，代码行数:13，代码来源:QueryDslSfmBenchmark.java

示例9: _16Fields

import com.mysema.commons.lang.CloseableIterator; //导入依赖的package包/类
@Benchmark
public void _16Fields(LimitParam limit, final Blackhole blackhole, ConnectionParam connectionParam) throws Exception {
	SQLQuery query = new SQLQuery(connectionParam.connection, templates);

	CloseableIterator<MappedObject16> iterate = query.from(QTestBenchmarkObject16.testBenchmarkObject16)
			.limit(limit.limit)
			.iterate(MAPPED_OBJECT_16_Q_BEAN);

	while(iterate.hasNext()) {
		blackhole.consume(iterate.next());
	}
}

开发者ID:arnaudroger，项目名称:mapping-benchmark，代码行数:13，代码来源:QueryDslSfmBenchmark.java

示例10: transform

import com.mysema.commons.lang.CloseableIterator; //导入依赖的package包/类
@Override
public R transform(FetchableQuery<?, ?> query) {
	CloseableIterator<T> iter = query.select(groupExpression.getExpression()).iterate();
	GroupCollector<T, R> collector = groupExpression.createGroupCollector();
	try {
		while (iter.hasNext()) {
			T collectable = iter.next();
			collector.add(collectable);
		}
	} finally {
		iter.close();
	}
	return collector.get();
}

开发者ID:openwide-java，项目名称:owsi-core-parent，代码行数:15，代码来源:GroupExpressionResultTransformer.java

示例11: findUtilizationsBetween

import com.mysema.commons.lang.CloseableIterator; //导入依赖的package包/类
@Transactional(readOnly = true, isolation = READ_COMMITTED, propagation = MANDATORY)
@Override
public CloseableIterator<Utilization> findUtilizationsBetween(UtilizationKey utilizationKey, DateTime start, DateTime end) {
    UtilizationSearch search = new UtilizationSearch();
    search.facilityIds.add(utilizationKey.facilityId);
    search.usages.add(utilizationKey.usage);
    search.capacityTypes.add(utilizationKey.capacityType);
    search.start = start;
    search.end = end;
    return findUtilizations(search);
}

开发者ID:HSLdevcom，项目名称:parkandrideAPI，代码行数:12，代码来源:UtilizationDao.java

示例12: findUtilizations

import com.mysema.commons.lang.CloseableIterator; //导入依赖的package包/类
@Transactional(readOnly = true, isolation = READ_COMMITTED, propagation = MANDATORY)
@Override
public CloseableIterator<Utilization> findUtilizations(UtilizationSearch search) {
    // TODO: add support for JDBC setFetchSize to QueryDSL, without it PostgreSQL will not stream results, but instead reads all results to memory
    final PostgreSQLQuery<Utilization> q = queryFactory.from(qUtilization).select(utilizationMapping);
    q.where(qUtilization.ts.between(search.start, search.end));
    addCriteria(q, search.facilityIds, qUtilization.facilityId);
    addCriteria(q, search.capacityTypes, qUtilization.capacityType);
    addCriteria(q, search.usages, qUtilization.usage);
    q.setStatementOptions(StatementOptions.builder().setFetchSize(100).build());
    return q.orderBy(qUtilization.ts.asc()).iterate();
}

开发者ID:HSLdevcom，项目名称:parkandrideAPI，代码行数:13，代码来源:UtilizationDao.java

示例13: getFacilityStats

import com.mysema.commons.lang.CloseableIterator; //导入依赖的package包/类
private Map<MaxUtilizationReportKeyWithDate, Integer> getFacilityStats(ReportContext ctx, ReportParameters parameters, UtilizationSearch search) {
    try (CloseableIterator<Utilization> utilizations = utilizationRepository.findUtilizations(search)) {
        return stream(spliteratorUnknownSize(addFilters(utilizations, ctx, parameters), Spliterator.ORDERED), false)
                .filter(u -> hasBuiltCapacity(u, ctx.facilities))
                .collect(toMap(
                        u -> new MaxUtilizationReportKeyWithDate(u, ctx.facilities.get(u.facilityId)),
                        u -> u.spacesAvailable,
                        Math::min,
                        LinkedHashMap::new
                ));
    }
}

开发者ID:HSLdevcom，项目名称:parkandrideAPI，代码行数:13，代码来源:MaxUtilizationReportService.java

示例14: predict

import com.mysema.commons.lang.CloseableIterator; //导入依赖的package包/类
@Override
public List<Prediction> predict(PredictorState state, UtilizationHistory history, int maxCapacity) {
    List<Prediction> predictions = new ArrayList<>();
    try (CloseableIterator<Utilization>  utilizations = history.getUpdatesSince(state.latestUtilization)) {
        stream(spliteratorUnknownSize(utilizations, NONNULL | IMMUTABLE), false)
            .reduce((older, newer) -> newer)
            .ifPresent(lastUpdate -> {
                state.latestUtilization = lastUpdate.timestamp;
                predictions.add(new Prediction(lastUpdate.timestamp, lastUpdate.spacesAvailable));
                predictions.add(new Prediction(lastUpdate.timestamp.plusDays(1), lastUpdate.spacesAvailable));
            });
    }
    return predictions;
}

开发者ID:HSLdevcom，项目名称:parkandrideAPI，代码行数:15，代码来源:SameAsLatestPredictor.java

示例15: getUpdatesSince

import com.mysema.commons.lang.CloseableIterator; //导入依赖的package包/类
@Override
public CloseableIterator<Utilization> getUpdatesSince(DateTime startExclusive) {
    return new IteratorAdapter<Utilization>(
            utilizationList.stream()
            .filter(utilization -> !utilization.timestamp.isBefore(startExclusive))
            .iterator()
    );
}

开发者ID:HSLdevcom，项目名称:parkandrideAPI，代码行数:9，代码来源:UtilizationHistoryList.java

示例16: findUtilizationsBetween_limits_to_start_and_end_time_inclusive_ordered_by_time

import com.mysema.commons.lang.CloseableIterator; //导入依赖的package包/类
@Test
public void findUtilizationsBetween_limits_to_start_and_end_time_inclusive_ordered_by_time() {
    Utilization u1 = newUtilization(facilityId, new DateTime(2000, 1, 1, 12, 0, 0, 1), 100, 100);
    Utilization u2 = newUtilization(facilityId, new DateTime(2000, 1, 1, 12, 0, 0, 2), 200, 200);
    Utilization u3 = newUtilization(facilityId, new DateTime(2000, 1, 1, 12, 0, 0, 3), 300, 300);
    Utilization u4 = newUtilization(facilityId, new DateTime(2000, 1, 1, 12, 0, 0, 4), 400, 400);
    Utilization u5 = newUtilization(facilityId, new DateTime(2000, 1, 1, 12, 0, 0, 5), 500, 500);
    UtilizationKey key = u1.getUtilizationKey();
    utilizationDao.insertUtilizations(asList(u1, u2, u3, u4, u5));

    try (CloseableIterator<Utilization> results = utilizationDao.findUtilizationsBetween(key, u2.timestamp, u4.timestamp)) {

        assertThat(results).containsExactly(u2, u3, u4);
    }
}

开发者ID:HSLdevcom，项目名称:parkandrideAPI，代码行数:16，代码来源:UtilizationDaoTest.java

示例17: findUtilizationsBetween_is_facility_specific

import com.mysema.commons.lang.CloseableIterator; //导入依赖的package包/类
@Test
public void findUtilizationsBetween_is_facility_specific() {
    DateTime time = new DateTime(2000, 1, 1, 12, 0);
    Utilization u1 = newUtilization(dummies.createFacility(), time, 100, 100);
    Utilization u2 = newUtilization(dummies.createFacility(), time, 200, 200);
    utilizationDao.insertUtilizations(asList(u1, u2));

    try (CloseableIterator<Utilization> results = utilizationDao.findUtilizationsBetween(u1.getUtilizationKey(), time, time)) {

        assertThat(results).containsExactly(u1);
    }
}

开发者ID:HSLdevcom，项目名称:parkandrideAPI，代码行数:13，代码来源:UtilizationDaoTest.java

示例18: findUtilizationsBetween_is_capacity_type_specific

import com.mysema.commons.lang.CloseableIterator; //导入依赖的package包/类
@Test
public void findUtilizationsBetween_is_capacity_type_specific() {
    DateTime time = new DateTime(2000, 1, 1, 12, 0);
    Utilization u1 = newUtilization(facilityId, time, 100, 100);
    u1.capacityType = CAR;
    Utilization u2 = newUtilization(facilityId, time, 200, 200);
    u2.capacityType = MOTORCYCLE;
    utilizationDao.insertUtilizations(asList(u1, u2));

    try (CloseableIterator<Utilization> results = utilizationDao.findUtilizationsBetween(u1.getUtilizationKey(), time, time)) {

        assertThat(results).containsExactly(u1);
    }
}

开发者ID:HSLdevcom，项目名称:parkandrideAPI，代码行数:15，代码来源:UtilizationDaoTest.java

示例19: findUtilizationsBetween_is_usage_specific

import com.mysema.commons.lang.CloseableIterator; //导入依赖的package包/类
@Test
public void findUtilizationsBetween_is_usage_specific() {
    DateTime time = new DateTime(2000, 1, 1, 12, 0);
    Utilization u1 = newUtilization(facilityId, time, 100, 100);
    u1.usage = COMMERCIAL;
    Utilization u2 = newUtilization(facilityId, time, 200, 200);
    u2.usage = HSL_TRAVEL_CARD;
    utilizationDao.insertUtilizations(asList(u1, u2));

    try (CloseableIterator<Utilization> results = utilizationDao.findUtilizationsBetween(u1.getUtilizationKey(), time, time)) {

        assertThat(results).containsExactly(u1);
    }
}

开发者ID:HSLdevcom，项目名称:parkandrideAPI，代码行数:15，代码来源:UtilizationDaoTest.java

示例20: update

import com.mysema.commons.lang.CloseableIterator; //导入依赖的package包/类
@Test
public void update() {
    tn.description = "howdy";
    tn.save();
    CloseableIterator<Map<String,NODE>> c = Ontology.sparql("select ?d where { ?tn a %TestNode . ?tn %description ?d }");
    assertTrue(c.hasNext());
    assertEquals(c.next().get("d").asLiteral().getValue(), "howdy");
}

开发者ID:meshnetinc，项目名称:gmantic，代码行数:9，代码来源:GmanticTest.java

注：本文中的com.mysema.commons.lang.CloseableIterator类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java DefaultDataType类代码示例发布时间：2022-05-22

Java DefaultGraphPath类代码示例发布时间：2022-05-22

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18248|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9671|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8175|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8547|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8455|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9384|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8426|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7859|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8410|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7394|2022-11-06

客服电话

电子邮件

Java CloseableIterator类代码示例

示例1: createSetFromTuples

示例2: iterate

示例3: findUtilizationsWithResolution

示例4: sparqlFind

示例5: sparql

示例6: selectAll

示例7: testCustomTransform

示例8: _04Fields

示例9: _16Fields

示例10: transform

示例11: findUtilizationsBetween

示例12: findUtilizations

示例13: getFacilityStats

示例14: predict

示例15: getUpdatesSince

示例16: findUtilizationsBetween_limits_to_start_and_end_time_inclusive_ordered_by_time

示例17: findUtilizationsBetween_is_facility_specific

示例18: findUtilizationsBetween_is_capacity_type_specific

示例19: findUtilizationsBetween_is_usage_specific

示例20: update

请发表评论

全部评论

上一篇：

下一篇：

bradtraversy/iweather: Ionic 3 mobile we

joaomh/curso-de-matlab

断牙刷新位置时间（断牙属性及刷新位置介绍

the-virtual-brain/tvb-library: DEPRECATE

rugk/mastodon-simplified-federation: Sim

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053