All Classes and Interfaces
Class
Description
Abstraction for arrays of objects and primitive types (most prominently byte).
Class for abstracting (bulk) operations on arrays.
Interface for putting an array of items into a sequence at a certain offset
Interface for an async cache that allows "claiming" entries.
Implementation of async claiming cache.
A base implementation of AutoClosable that helps detecting resource leaks.
The batcher transform an iterator of input items into an iterator of batches.
Batch implementation backed by a navigable map.
Rewriter for instantiating a query such that a list of initial bindings are injected.
Rewrite result of a bulk service request.
BufferLike is a common interface for Buffer and RangeBuffer.
A property function for listing the cache's content.
Invalidate the given keys (or all if none are given).
Do not register directly - use
ChainingServiceExecutorBulkServiceEnhancer which gives more control over
when to use this in a service executor chainAssembler that sets up a base dataset's context with the service enhancer machinery.
Interface typically used for removing listener registrations
An estimated value with a flag that indicates whether it's exact.
Force all actions in a list to run.
Interface that combines a group key with a
BatchImplementation that combines a batch with a group key.
Interface for retrieving
ArrayOpsBuffering iterator.
Interface for directly executing
OpService instancesHelper class to simplify executing concrete OpService instances
Class used to map a given scoped OpService to a normalized form.
Interface to ease working with fixed size pages.
Utility methods for working with (fixed-size) pages.
Helper class to capture a range of data (specified by limit + offset)
w.r.t. a partition key (typically a
Binding
and give that information an id.The atlas version does active read ahead; this one only fetches data when needed
Deferred (lazy) iterator which initializes a delegate from a supplier only when needed
QueryIter to process service requests in bulk with support for streaming caching.
QueryIterator implementation based on IteratorSlotted.
Utility methods for working with guava
Range instancesA data stream allows for repeated retrieval of arrays of consecutive items.
Exception used with
RangeBuffer when attempting to read a range of data
for which there exist one or more gaps in the buffer.Interface for nested references.
Interface with default methods that delegate Ref's methods
Essentially a typedef for
Ref<CompletableFuture<T>>Implementation of a
Ref.Prepare and execute bulk requests
Examples for setting up and using SERVICE caching
Vocabulary for assembler-based configuration of the service enhancer plugin
Utilities to exploit url scheme pattern to represent key value pairs.
A mapping of service IRIs to result set size limits.
An abstract base class for iterating over containers of unknown size.
A concurrently accessible sequence of data of possibly unknown size.
Abstraction over a sequence of pages to view their content as
consecutive items.
A sequence of claimed ranges within a certain range, whereas the range
can be modified resulting in an incremental change of the claims.
A slice implementation that starts to discard pages once there are too many.
A key object capturing the id of an input binding and an id for a
corresponding consecutive range of data which needs to be accessed/retrieved.
Detects options on SERVICE and materializes them.
Checks for the presence of
SERVICE <loop:> { }
transforms those into linear joins using OpSequence / OpDisjunction
and adjust variable scopes.It seems that preemtive optimization before execution does not work with property
functions.
Methods for working with scope levels of SPARQL variables.