本文整理了Java中java.util.stream.Stream.unordered()
方法的一些代码示例,展示了Stream.unordered()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Stream.unordered()
方法的具体详情如下:
包路径:java.util.stream.Stream
类名称: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);
}
内容来源于网络,如有侵权,请联系作者删除!