Module org.apache.jena.arq

Package org.apache.jena.sparql.util.compose

Class DatasetCollector.ConcurrentDatasetCollector

java.lang.Object

org.apache.jena.sparql.util.compose.DatasetCollector

org.apache.jena.sparql.util.compose.DatasetCollector.ConcurrentDatasetCollector

All Implemented Interfaces:

Collector<Dataset,Dataset,Dataset>, org.apache.jena.atlas.lib.IdentityFinishCollector<Dataset,Dataset>, org.apache.jena.atlas.lib.IdentityFinishCollector.ConcurrentUnorderedIdentityFinishCollector<Dataset,Dataset>, org.apache.jena.atlas.lib.IdentityFinishCollector.UnorderedIdentityFinishCollector<Dataset,Dataset>

Enclosing class:

DatasetCollector

public static class DatasetCollector.ConcurrentDatasetCollector
extends DatasetCollector
implements org.apache.jena.atlas.lib.IdentityFinishCollector.ConcurrentUnorderedIdentityFinishCollector<Dataset,Dataset>

Use only with Datasets that support transactions.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.jena.sparql.util.compose.DatasetCollector

DatasetCollector.ConcurrentDatasetCollector, DatasetCollector.IntersectionDatasetCollector, DatasetCollector.UnionDatasetCollector

Nested classes/interfaces inherited from interface java.util.stream.Collector

Collector.Characteristics

Nested classes/interfaces inherited from interface org.apache.jena.atlas.lib.IdentityFinishCollector

org.apache.jena.atlas.lib.IdentityFinishCollector.ConcurrentUnorderedIdentityFinishCollector<T extends Object,A extends Object>, org.apache.jena.atlas.lib.IdentityFinishCollector.UnorderedIdentityFinishCollector<T extends Object,A extends Object>

Constructor Summary

Constructors

Constructor	Description
ConcurrentDatasetCollector(DatasetCollector col)

Method Summary

Modifier and Type	Method	Description
BiConsumer<Dataset,Dataset>	accumulator()
BinaryOperator<Dataset>	combiner()

Methods inherited from class org.apache.jena.sparql.util.compose.DatasetCollector

concurrent, supplier

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.stream.Collector

supplier

Methods inherited from interface org.apache.jena.atlas.lib.IdentityFinishCollector

finisher

Methods inherited from interface org.apache.jena.atlas.lib.IdentityFinishCollector.ConcurrentUnorderedIdentityFinishCollector

characteristics

Constructor Details

ConcurrentDatasetCollector

public ConcurrentDatasetCollector(DatasetCollector col)

Method Details

combiner

public BinaryOperator<Dataset> combiner()

Specified by:

combiner in interface Collector<Dataset,Dataset,Dataset>

accumulator

public BiConsumer<Dataset,Dataset> accumulator()

Specified by:

accumulator in interface Collector<Dataset,Dataset,Dataset>