Uses of Class
eu.fbk.knowledgestore.data.Stream

Packages that use Stream

Package	Description
eu.fbk.knowledgestore	KnowledgeStore core API (ks-core).
eu.fbk.knowledgestore.data	Data objects and supporting classes (ks-core).
eu.fbk.knowledgestore.datastore	DataStore server-side component API (ks-server).
eu.fbk.knowledgestore.datastore.hbase	DataStore implementation based on Apache HBase (ks-server-hbase).
eu.fbk.knowledgestore.elastic
eu.fbk.knowledgestore.filestore	FileStore server-side component API (ks-server).

Uses of Stream in eu.fbk.knowledgestore

Methods in eu.fbk.knowledgestore that return Stream

Modifier and Type	Method and Description
static Stream<Outcome>	Outcome.decode(Stream<org.openrdf.model.Statement> stream, Boolean chunked) Performs RDF-to-outcome decoding by converting a stream of RDF statements in a stream of outcomes.
protected abstract <T> Stream<T>	Operation.Sparql.doExec(Long timeout, Class<T> type, String expression, Set<org.openrdf.model.URI> defaultGraphs, Set<org.openrdf.model.URI> namedGraphs) Implementation method responsible of executing the SPARQL operation.
protected abstract Stream<Record>	Operation.Match.doExec(Long timeout, Map<org.openrdf.model.URI,XPath> conditions, Map<org.openrdf.model.URI,Set<org.openrdf.model.URI>> ids, Map<org.openrdf.model.URI,Set<org.openrdf.model.URI>> properties)
protected abstract Stream<Record>	Operation.Retrieve.doExec(Long timeout, org.openrdf.model.URI type, XPath condition, Set<org.openrdf.model.URI> ids, Set<org.openrdf.model.URI> properties, Long offset, Long limit)
protected abstract Stream<Record>	AbstractSession.doMatch(Long timeout, Map<org.openrdf.model.URI,XPath> conditions, Map<org.openrdf.model.URI,Set<org.openrdf.model.URI>> ids, Map<org.openrdf.model.URI,Set<org.openrdf.model.URI>> properties)
protected abstract Stream<Record>	AbstractSession.doRetrieve(Long timeout, org.openrdf.model.URI type, XPath condition, Set<org.openrdf.model.URI> ids, Set<org.openrdf.model.URI> properties, Long offset, Long limit)
protected abstract <T> Stream<T>	AbstractSession.doSparql(Long timeout, Class<T> type, String expression, Set<org.openrdf.model.URI> defaultGraphs, Set<org.openrdf.model.URI> namedGraphs)
static Stream<org.openrdf.model.Statement>	Outcome.encode(Stream<? extends Outcome> stream) Performs outcome-to-RDF encoding by converting a stream of outcomes in a stream of RDF statements.
Stream<Record>	Operation.Retrieve.exec()
Stream<Record>	Operation.Match.exec()
Stream<org.openrdf.model.Statement>	Operation.Sparql.execTriples() Evaluates the query, returning a Stream with the resulting Statements; applicable to CONSTRUCT and DESCRIBE queries.
Stream<org.openrdf.query.BindingSet>	Operation.Sparql.execTuples() Evaluates the query, returning a Stream with the resulting BindingSets; applicable to SELECT queries.

Methods in eu.fbk.knowledgestore with parameters of type Stream

Modifier and Type	Method and Description
static Stream<Outcome>	Outcome.decode(Stream<org.openrdf.model.Statement> stream, Boolean chunked) Performs RDF-to-outcome decoding by converting a stream of RDF statements in a stream of outcomes.
protected abstract void	AbstractSession.doCreate(Long timeout, org.openrdf.model.URI type, Stream<? extends Record> records, Handler<? super Outcome> handler)
protected abstract Outcome	Operation.SparqlUpdate.doExec(Long timeout, Stream<? extends org.openrdf.model.Statement> statements)
protected abstract Outcome	Operation.SparqlDelete.doExec(Long timeout, Stream<? extends org.openrdf.model.Statement> statements)
protected abstract Outcome	Operation.Merge.doExec(Long timeout, org.openrdf.model.URI type, Stream<? extends Record> stream, Criteria criteria, Handler<? super Outcome> handler)
protected abstract Outcome	Operation.Create.doExec(Long timeout, org.openrdf.model.URI type, Stream<? extends Record> records, Handler<? super Outcome> handler)
protected abstract void	AbstractSession.doMerge(Long timeout, org.openrdf.model.URI type, Stream<? extends Record> records, Criteria criteria, Handler<? super Outcome> handler)
protected abstract Outcome	AbstractSession.doSparqlDelete(Long timeout, Stream<? extends org.openrdf.model.Statement> statements)
protected abstract Outcome	AbstractSession.doSparqlUpdate(Long timeout, Stream<? extends org.openrdf.model.Statement> statements)
static Stream<org.openrdf.model.Statement>	Outcome.encode(Stream<? extends Outcome> stream) Performs outcome-to-RDF encoding by converting a stream of outcomes in a stream of RDF statements.

Uses of Stream in eu.fbk.knowledgestore.data

Methods in eu.fbk.knowledgestore.data that return Stream

Modifier and Type	Method and Description
Stream<List<T>>	Stream.chunk(int chunkSize) Intermediate operation returning a Stream of elements chunks of the specified size obtained from this Stream (the last chunk may be smaller).
static <T> Stream<T>	Stream.concat(Iterable<? extends Iterable<? extends T>> iterables) Returns a Stream concatenating zero or more Iterables.
static <T> Stream<T>	Stream.concat(Iterable<? extends T>... iterables) Returns a Stream concatenating zero or more Iterables.
static <T> Stream<T>	Stream.create(Enumeration<? extends T> enumeration) Creates a new Stream over the elements returned by the supplied Enumeration.
static <T> Stream<T>	Stream.create(Iterable<? extends T> iterable) Creates a new Stream over the elements of the supplied Iterable.
static <T> Stream<T>	Stream.create(info.aduna.iteration.Iteration<? extends T,?> iteration) Creates a new Stream over the elements returned by the supplied Sesame Iteration.
static <T> Stream<T>	Stream.create(Iterator<? extends T> iterator) Creates a new Stream over the elements returned by the supplied Iterator.
static <T> Stream<T>	Stream.create(T... elements) Creates a new Stream for the supplied elements.
static Stream<Record>	Record.decode(Stream<org.openrdf.model.Statement> stream, Iterable<? extends org.openrdf.model.URI> types, Boolean chunked) Performs RDF-to-record decoding by converting a stream of RDF statements in a stream of records.
Stream<T>	Stream.distinct() Intermediate operation returning a Stream with only the distinct elements of this Stream.
static Stream<org.openrdf.model.Statement>	Record.encode(Stream<? extends Record> stream, Iterable<? extends org.openrdf.model.URI> types) Performs record-to-RDF encoding by converting a stream of records in a stream of RDF statements.
Stream<T>	Stream.filter(Predicate<? super T> predicate, int parallelism) Intermediate operation returning a Stream with only the elements of this Stream that satisfy the specified predicate.
Stream<T>	Stream.onClose(Object... objects) Register zero or more objects for activation when this Stream will be closed.
Stream<T>	Stream.setProperty(String name, Object value) Sets a metadata property about the stream.
Stream<T>	Stream.setTimeout(Long timestamp) Sets a timeout by supplying the absolute milliseconds timestamp when the Stream will be forcedly closed.
Stream<T>	Stream.slice(long offset, long limit) Intermediate operation returning a Stream with max limit elements with index starting at offset taken from this Stream.
Stream<T>	Stream.track(AtomicLong counter, AtomicBoolean eof) Intermediate operation returning a Stream that returns the elements of this Stream and tracks the number of elements returned so far.
<R> Stream<R>	Stream.transform(Class<R> type, boolean lenient, Object... path) Intermediate operation returning a Stream with the elements obtained by applying an optional navigation path and conversion to a certain type to the elements of this Stream.
<R> Stream<R>	Stream.transform(Function<? super T,? extends R> function, int parallelism) Intermediate operation returning a Stream with the elements obtained from the ones of this Stream by applying the specified transformation function.
<R> Stream<R>	Stream.transform(Function<Iterator<T>,Iterator<R>> iteratorFunction, Function<Handler<R>,Handler<T>> handlerFunction) Intermediate operation returning a Stream with the elements obtained by applying the supplied transformation functions to the Iterator and Handler returned / accepted by this Stream.

Methods in eu.fbk.knowledgestore.data with parameters of type Stream

Modifier and Type	Method and Description
static Stream<Record>	Record.decode(Stream<org.openrdf.model.Statement> stream, Iterable<? extends org.openrdf.model.URI> types, Boolean chunked) Performs RDF-to-record decoding by converting a stream of RDF statements in a stream of records.
static Stream<org.openrdf.model.Statement>	Record.encode(Stream<? extends Record> stream, Iterable<? extends org.openrdf.model.URI> types) Performs record-to-RDF encoding by converting a stream of records in a stream of RDF statements.

Uses of Stream in eu.fbk.knowledgestore.datastore

Methods in eu.fbk.knowledgestore.datastore that return Stream

Modifier and Type	Method and Description
Stream<Record>	SolrDataStore.SolrTransaction.lookup(org.openrdf.model.URI type, Set<? extends org.openrdf.model.URI> ids, Set<? extends org.openrdf.model.URI> properties)
Stream<Record>	MySQLDataStore.MySQLTransaction.lookup(org.openrdf.model.URI type, Set<? extends org.openrdf.model.URI> ids, Set<? extends org.openrdf.model.URI> properties)
Stream<Record>	ForwardingDataTransaction.lookup(org.openrdf.model.URI type, Set<? extends org.openrdf.model.URI> ids, Set<? extends org.openrdf.model.URI> properties)
Stream<Record>	DataTransaction.lookup(org.openrdf.model.URI type, Set<? extends org.openrdf.model.URI> ids, Set<? extends org.openrdf.model.URI> properties) Returns a stream of records having the type and IDs specified.
Stream<Record>	SolrDataStore.SolrTransaction.match(Map<org.openrdf.model.URI,XPath> conditions, Map<org.openrdf.model.URI,Set<org.openrdf.model.URI>> ids, Map<org.openrdf.model.URI,Set<org.openrdf.model.URI>> properties)
Stream<Record>	MySQLDataStore.MySQLTransaction.match(Map<org.openrdf.model.URI,XPath> conditions, Map<org.openrdf.model.URI,Set<org.openrdf.model.URI>> ids, Map<org.openrdf.model.URI,Set<org.openrdf.model.URI>> properties)
Stream<Record>	ForwardingDataTransaction.match(Map<org.openrdf.model.URI,XPath> conditions, Map<org.openrdf.model.URI,Set<org.openrdf.model.URI>> ids, Map<org.openrdf.model.URI,Set<org.openrdf.model.URI>> properties)
Stream<Record>	DataTransaction.match(Map<org.openrdf.model.URI,XPath> conditions, Map<org.openrdf.model.URI,Set<org.openrdf.model.URI>> ids, Map<org.openrdf.model.URI,Set<org.openrdf.model.URI>> properties) Evaluates a match request with the parameters supplied.
Stream<Record>	SolrDataStore.SolrTransaction.retrieve(org.openrdf.model.URI type, XPath condition, Set<? extends org.openrdf.model.URI> properties)
Stream<Record>	MySQLDataStore.MySQLTransaction.retrieve(org.openrdf.model.URI type, XPath condition, Set<? extends org.openrdf.model.URI> properties)
Stream<Record>	ForwardingDataTransaction.retrieve(org.openrdf.model.URI type, XPath condition, Set<? extends org.openrdf.model.URI> properties)
Stream<Record>	DataTransaction.retrieve(org.openrdf.model.URI type, XPath condition, Set<? extends org.openrdf.model.URI> properties) Returns a stream of records having the type and matching the optional condition specified.

Uses of Stream in eu.fbk.knowledgestore.datastore.hbase

Methods in eu.fbk.knowledgestore.datastore.hbase that return Stream

Modifier and Type	Method and Description
Stream<Record>	HBaseDataTransaction.lookup(org.openrdf.model.URI type, Set<? extends org.openrdf.model.URI> ids, Set<? extends org.openrdf.model.URI> properties)
Stream<Record>	HBaseDataTransaction.match(Map<org.openrdf.model.URI,XPath> conditions, Map<org.openrdf.model.URI,Set<org.openrdf.model.URI>> ids, Map<org.openrdf.model.URI,Set<org.openrdf.model.URI>> properties)
Stream<Record>	HBaseDataTransaction.retrieve(org.openrdf.model.URI type, XPath condition, Set<? extends org.openrdf.model.URI> properties)

Uses of Stream in eu.fbk.knowledgestore.elastic

Subclasses of Stream in eu.fbk.knowledgestore.elastic

Modifier and Type	Class and Description
class	SearchResponseStream

Methods in eu.fbk.knowledgestore.elastic that return Stream

Modifier and Type	Method and Description
Stream<Record>	DataTransactionElastic.lookup(org.openrdf.model.URI type, Set<? extends org.openrdf.model.URI> ids, Set<? extends org.openrdf.model.URI> properties) search for the specified ids in the database
Stream<Record>	DataTransactionElastic.match(Map<org.openrdf.model.URI,XPath> conditions, Map<org.openrdf.model.URI,Set<org.openrdf.model.URI>> ids, Map<org.openrdf.model.URI,Set<org.openrdf.model.URI>> properties)
Stream<Record>	DataTransactionElastic.retrieve(org.openrdf.model.URI type, XPath condition, Set<? extends org.openrdf.model.URI> properties) returns all the documents in the database that match the conditions

Uses of Stream in eu.fbk.knowledgestore.filestore

Methods in eu.fbk.knowledgestore.filestore that return Stream

Modifier and Type	Method and Description
Stream<String>	SynchronizedFileStore.list()
Stream<String>	MultiFileStore.list()
Stream<String>	LoggingFileStore.list()
Stream<String>	HadoopFileStore.list()
Stream<String>	GzippedFileStore.list()
Stream<String>	ForwardingFileStore.list()
Stream<String>	FileStore.list() Lists all the files stored on the FileStore.