java.util.stream.Stream.count()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(6.4k)|赞(0)|评价(0)|浏览(266)

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

Stream.count介绍

暂无

代码示例

代码示例来源：origin: JanusGraph/janusgraph

  1. public static void assertCount(long expected, Stream stream) {
  2.   org.junit.Assert.assertEquals(expected, stream.count());
  3. }

代码示例来源：origin: prestodb/presto

  1. private static int getNullFlagsCount(List<ArgumentProperty> argumentProperties)
  2. {
  3.   return (int) argumentProperties.stream()
  4.       .filter(argumentProperty -> argumentProperty.getNullConvention() == USE_NULL_FLAG)
  5.       .count();
  6. }

代码示例来源：origin: floragunncom/search-guard

  1. public boolean impliesClusterPermissionPermission(String action) {
  2.   return roles.stream()
  3.       .filter(r->r.impliesClusterPermission(action)).count() > 0;
  4. }

代码示例来源：origin: goldmansachs/gs-collections

  1. @Benchmark
  2. public void serial_lazy_jdk()
  3. {
  4.   long evens = this.integersJDK.stream().filter(each -> each % 2 == 0).count();
  5.   Assert.assertEquals(SIZE / 2, evens);
  6. }

代码示例来源：origin: kiegroup/optaplanner

  1. public int missingSpeakerPreferredTimeslotTagCount() {
  2.   if (timeslot == null) {
  3.     return 0;
  4.   }
  5.   return (int) speakerList.stream().flatMap(speaker -> speaker.getPreferredTimeslotTagSet().stream())
  6.       .filter(tag -> !timeslot.hasTag(tag)).count();
  7. }

代码示例来源：origin: AxonFramework/AxonFramework

  1. @Test
  2. public void testLoadNonExistent() {
  3.   assertEquals(0L, testSubject.readEvents(randomUUID().toString()).asStream().count());
  4. }

代码示例来源：origin: goldmansachs/gs-collections

  1. @Benchmark
  2. public void parallel_lazy_jdk()
  3. {
  4.   long evens = this.integersJDK.parallelStream().filter(each -> each % 2 == 0).count();
  5.   Assert.assertEquals(SIZE / 2, evens);
  6. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Test
  2. public void streamIsEmptyForEmptyValues() {
  3.   MutablePropertyValues pvs = new MutablePropertyValues();
  4.   assertThat(pvs.stream(), notNullValue());
  5.   assertThat(pvs.stream().count(), is(0L));
  6. }

代码示例来源：origin: OpenHFT/Chronicle-Queue

  1. @Test
  2. public void shouldNotRewindPastStartOfQueueWhenDisplayingHistory() {
  3.   basicReader().historyRecords(Long.MAX_VALUE).execute();
  4.   assertThat(capturedOutput.stream().
  5.       filter(msg -> !msg.startsWith("0x")).count(), is(24L));
  6. }

代码示例来源：origin: prestodb/presto

  1. private static boolean hasMixedDistinctAndNonDistincts(AggregationNode aggregation)
  2. {
  3.   long distincts = aggregation.getAggregations()
  4.       .values().stream()
  5.       .map(Aggregation::getCall)
  6.       .filter(FunctionCall::isDistinct)
  7.       .count();
  8.   return distincts > 0 && distincts < aggregation.getAggregations().size();
  9. }

代码示例来源：origin: reactor/reactor-core

  1. @Test
  2. public void streamAlreadyConsumed() {
  3.   AssertSubscriber<Integer> ts = AssertSubscriber.create();
  4.   Stream<Integer> s = source.stream();
  5.   s.count();
  6.   Flux.fromStream(s)
  7.     .subscribe(ts);
  8.   ts.assertNoValues()
  9.    .assertNotComplete()
  10.    .assertError(IllegalStateException.class);
  11. }

代码示例来源：origin: prestodb/presto

  1. @Test
  2. public void testNonDeterministic()
  3. {
  4.   MaterializedResult materializedResult = computeActual("SELECT rand() FROM orders LIMIT 10");
  5.   long distinctCount = materializedResult.getMaterializedRows().stream()
  6.       .map(row -> row.getField(0))
  7.       .distinct()
  8.       .count();
  9.   assertTrue(distinctCount >= 8, "rand() must produce different rows");
  10.   materializedResult = computeActual("SELECT apply(1, x -> x + rand()) FROM orders LIMIT 10");
  11.   distinctCount = materializedResult.getMaterializedRows().stream()
  12.       .map(row -> row.getField(0))
  13.       .distinct()
  14.       .count();
  15.   assertTrue(distinctCount >= 8, "rand() must produce different rows");
  16. }

代码示例来源：origin: goldmansachs/gs-collections

  1. @Benchmark
  2. public void serial_lazy_jdk()
  3. {
  4.   long evens = this.integersJDK.stream().filter(each -> each % 2 == 0).count();
  5.   Assert.assertEquals(SIZE / 2, evens);
  6. }

代码示例来源：origin: prestodb/presto

  1. private static int getBlockPositionCount(List<ArgumentProperty> argumentProperties)
  2. {
  3.   return (int) argumentProperties.stream()
  4.       .filter(argumentProperty -> argumentProperty.getNullConvention() == BLOCK_AND_POSITION)
  5.       .count();
  6. }

代码示例来源：origin: kiegroup/optaplanner

  1. public int prevailingSpeakerUndesiredTimeslotTagCount() {
  2.   if (timeslot == null) {
  3.     return 0;
  4.   }
  5.   return (int) speakerList.stream().flatMap(speaker -> speaker.getUndesiredTimeslotTagSet().stream())
  6.       .filter(tag -> timeslot.hasTag(tag)).count();
  7. }

代码示例来源：origin: JanusGraph/janusgraph

  1. @Test
  2. public void largeTest() throws Exception {
  3.   final int numDoc = 30000;
  4.   final String store = "vertex";
  5.   initialize(store);
  6.   for (int i = 1; i <= numDoc; i++) {
  7.     add(store, "doc" + i, getRandomDocument(), true);
  8.   }
  9.   clopen();
  10.   final long time = System.currentTimeMillis();
  11.   Stream<String> result = tx.queryStream(new IndexQuery(store, And.of(PredicateCondition.of(WEIGHT, Cmp.GREATER_THAN_EQUAL, 0.2), PredicateCondition.of(WEIGHT, Cmp.LESS_THAN, 0.6), PredicateCondition.of(LOCATION, Geo.WITHIN, Geoshape.circle(48.5, 0.5, 1000.00)))));
  12.   final long oldResultSize = result.count();
  13.   System.out.println(oldResultSize + " vs " + (numDoc / 1000 * 2.4622623015));
  14.   System.out.println("Query time on " + numDoc + " docs (ms): " + (System.currentTimeMillis() - time));
  15.   result = tx.queryStream(new IndexQuery(store, And.of(PredicateCondition.of(WEIGHT, Cmp.GREATER_THAN_EQUAL, 0.2), PredicateCondition.of(WEIGHT, Cmp.LESS_THAN, 0.6), PredicateCondition.of(LOCATION, Geo.WITHIN, Geoshape.circle(48.5, 0.5, 1000.00))), numDoc / 1000));
  16.   assertEquals(numDoc / 1000, result.count());
  17.   result = tx.queryStream(new IndexQuery(store, And.of(PredicateCondition.of(WEIGHT, Cmp.GREATER_THAN_EQUAL, 0.2), PredicateCondition.of(WEIGHT, Cmp.LESS_THAN, 0.6), PredicateCondition.of(LOCATION, Geo.WITHIN, Geoshape.circle(48.5, 0.5, 1000.00))), numDoc / 1000 * 100));
  18.   assertEquals(oldResultSize, result.count());
  19. }

代码示例来源：origin: SonarSource/sonarqube

  1. private void checkAtLeastOneActionIsDefined(Set<String> actions) {
  2.  long actionsDefined = actions.stream().filter(action -> !action.equals(COMMENT_KEY)).count();
  3.  checkArgument(actionsDefined > 0, "At least one action must be provided");
  4. }

代码示例来源：origin: goldmansachs/gs-collections

  1. @Benchmark
  2. public void parallel_lazy_jdk()
  3. {
  4.   long evens = this.integersJDK.parallelStream().filter(each -> each % 2 == 0).count();
  5.   Assert.assertEquals(SIZE / 2, evens);
  6. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Test
  2. public void streamIsEmptyForEmptySources() {
  3.   MutablePropertySources sources = new MutablePropertySources();
  4.   assertThat(sources.stream(), notNullValue());
  5.   assertThat(sources.stream().count(), is(0L));
  6. }

代码示例来源：origin: OpenHFT/Chronicle-Queue

  1. @Test
  2. public void shouldFilterByMultipleExclusionRegex() {
  3.   basicReader().withExclusionRegex(".*bye$").withExclusionRegex(".*ell.*").execute();
  4.   assertThat(capturedOutput.stream().filter(msg -> !msg.startsWith("0x")).count(), is(0L));
  5. }

内容来源于网络，如有侵权，请联系作者删除！

Stream

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com