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

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

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

Stream.unordered介绍

暂无

代码示例

代码示例来源:origin: speedment/speedment

/**
 * Returns an equivalent stream that is
 * <a href="package-summary.html#Ordering">unordered</a>.  May return
 * itself, either because the stream was already unordered, or because
 * the underlying stream state was modified to be unordered.
 * <p>
 * This is an intermediate operation.
 *
 * @return an unordered stream
 */
@Override
public MapStream<K, V> unordered() {
  inner = inner.unordered();
  return this;
}

代码示例来源:origin: speedment/speedment

@Override
public Stream<T> unordered() {
  return wrap(stream().unordered());
}

代码示例来源:origin: speedment/speedment

result = result.unordered();

代码示例来源:origin: stanfordnlp/CoreNLP

AtomicInteger datasize = new AtomicInteger(0);
Counter<SentimentClass> distribution = new ClassicCounter<>();
data.unordered().parallel()
  .map(datum -> {
   if (datasize.incrementAndGet() % 10000 == 0) {

代码示例来源:origin: lenskit/lenskit

@Override
public Stream<T> unordered() {
  return stream().unordered();
}

代码示例来源:origin: my2iu/Jinq

@Override
public Stream<T> unordered()
{
 realizeStream();
 return wrap(wrappedStream.unordered());
}

代码示例来源:origin: padreati/rapaio

@Override
public FSpots unordered() {
  stream = stream.unordered();
  return this;
}

代码示例来源:origin: jenetics/jenetics

@Override
public Stream<T> unordered() {
  return _self.unordered();
}

代码示例来源:origin: numenta/htm.java

@Override
public Stream<T> unordered() {
  return delegate.unordered();
}

代码示例来源:origin: padreati/rapaio

@Override
public VSpots unordered() {
  stream = stream.unordered();
  return this;
}

代码示例来源:origin: zeebe-io/zeebe

@Override
public S unordered() {
 return supply(wrappedStream.unordered());
}

代码示例来源:origin: OpenGamma/Strata

@Override
public MapStream<K, V> unordered() {
 return wrap(underlying.unordered());
}

代码示例来源:origin: poetix/protonpack

@Override
public MapStream<K, V> unordered() {
  return new DefaultMapStream<>(delegate.unordered());
}

代码示例来源:origin: com.codepoetics/protonpack

@Override
public MapStream<K, V> unordered() {
  return new DefaultMapStream<>(delegate.unordered());
}

代码示例来源:origin: ripreal/V8LogScanner

private List<String> filterLogs(ArrayList<String> mapList) {
  return mapList.
      parallelStream().
      unordered().
      filter(n -> pattern.matcher(n).matches()).
      sequential().
      sorted(RgxOpManager::compare).
      collect(Collectors.toList());
}

代码示例来源:origin: com.oracle.bedrock/bedrock-runtime

@Override
  public Platform getPlatform(Option... options)
  {
    OptionsByType      optionsByType = OptionsByType.of(options);

    PlatformPredicate  predicate     = optionsByType.getOrDefault(PlatformPredicate.class, PlatformPredicate.any());

    Optional<Platform> platform      = platforms.stream().filter(predicate).unordered().findFirst();

    return platform.isPresent() ? platform.get() : null;
  }
}

代码示例来源:origin: coherence-community/oracle-bedrock

@Override
  public Platform getPlatform(Option... options)
  {
    OptionsByType      optionsByType = OptionsByType.of(options);

    PlatformPredicate  predicate     = optionsByType.getOrDefault(PlatformPredicate.class, PlatformPredicate.any());

    Optional<Platform> platform      = platforms.stream().filter(predicate).unordered().findFirst();

    return platform.isPresent() ? platform.get() : null;
  }
}

代码示例来源:origin: org.fcrepo/fcrepo-kernel-api

@Override
  public RdfStream unordered() {
    return new DefaultRdfStream(topic(), stream.unordered());
  }
}

代码示例来源:origin: commons-rdf/commons-rdf

@Test
public void writeGraphFromStream() throws Exception {
  Path graphFile = Files.createTempFile("graph", ".nt");
  if (KEEP_FILES) {
    System.out.println("From stream: " + graphFile);
  } else {
    graphFile.toFile().deleteOnExit();
  }
  Stream<CharSequence> stream = graph.getTriples().unordered()
      .map(Object::toString);
  Files.write(graphFile, stream::iterator, Charset.forName("UTF-8"));
}

代码示例来源:origin: commons-rdf/commons-rdf

@Test
public void countQuery() {
  BlankNode subject = new BlankNodeImpl(Optional.of(graph), "subj");
  IRI predicate = new IRIImpl("pred");
  long count = graph.getTriples(subject, predicate, null).unordered()
      .parallel().count();
  System.out.println("Counted - " + count);
}

相关文章