|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
HistoryTable.a.
WriteCacheService (if enabled).
AbstractJournal.abort(),
reloading all state from the last root block, etc.
IAsynchronousClientTask.AbstractBTree.ITuple that directly supports forward and reverse cursor
operations on a local mutable BTree.ITuple that directly supports forward and reverse cursor
operations on a local BTree.IBufferStrategy implementation.LookupCache to
reduce round trips to the discovered ServiceRegistrars for a
specific class of services.IChunkedIterator and asynchronously resolves chunks.ResultSet at a time.ITuple that draws its data from a ResultSet.IBigdataClient implementations.UnsupportedOperationException for all
mutation operations.IBigdataFederation implementations where the
services are distributed using RMI and are running, at least in principle,
across more than one host/JVM.IBuffer of IRelation elements whose target is
a mutation (insert, delete, or update) of some IMutableRelation.IMutableRelation.delete(IChunkedOrderedIterator)
when it is flushed.IMutableRelation.insert(IChunkedOrderedIterator)
when it is flushed.IBigdataFederation implementations.ILoadBalancerService.AbstractStatisticsCollector, an
(optional) httpd service, and the (required) AbstractFederation.ReportTask.INSERT DATA and
DELETE DATA operations.NanoHTTPD to (a) prevent serving files from
the local file system; and (b) to expose methods for handling GET, PUT, POST,
and DELETE requests - these methods all return a
NanoHTTPD.HTTP_METHOD_NOT_ALLOWED NanoHTTPD.Response by default.IIndex like objects.ReadIndexTask and
CountIndexTask.IExtensionIVs.IJoinNexusIJoinNexusFactory.Quorum.
IKeyArrayIndexProcedure execution (procedures may be executed on a
local index, but they are only (de-)serialized when executed on a remote
index).boolean[] back from a
remote procedure call.true bits in the AbstractKeyArrayIndexProcedure.ResultBitBuffer(s).AbstractKeyArrayIndexProcedure.ResultBitBuffer objects.byte[][]).AbstractKeyArrayIndexProcedure.ResultBuffer objects.IKeyArrayIndexProcedures so that their data may be key
range partitions and mapped against each relevant index partition.Journal or for an IDataService in an
IBigdataFederation.ITripleStore
implementations using local storage.AbstractMasterTask
and a factory for the statistics for the subtasks.BlockingBuffer and distributes those chunks to
subtasks according to some abstraction which is not defined by this class.IVs which use the extension bit
and distinguish themselves by an extension byte
following the flags byte.IVs which CAN NOT be fully materialized
from their inline representation.IAsynchronousClientTask, to track the set of outstanding
asynchronous operations for a specific client task (the "pending set"), and
to close the client task when the sink not assign any more work to that
client.Runnable that reads the output of an ActiveProcess.#start() to begin
operations.
QuorumActor implementations.QuorumWatcher implementations.QuorumClients.QuorumMember.IRawStore implementations.IRawStore implementations that use an
append only (Write Once, Read Many) strategy.IRelation and IMutableRelation impls.ResourceManager.IResourceMetadata implementations.(?x, {P}, ?y) -> (?x, propertyId, ?y)
Note: Both the database and the (optional) focusStore relation names
MUST be declared for these rules.
P).IRunningQuery implementations.AbstractScaleOutFederations.PartitionLocators for an
IMetadataIndex.AbstractScaleOutClient.IScaleOutClientIndex implementation(s).DataService to purge any unused resources and to
optionally truncate the extent of the live journal.Configuration data from the file or URL
named by args and applies any optional overrides, starts the
service, and advertises the service for discovery.
UUID,
etc.LoadBalancerService.IBuffer whose target is a mutation (insert, delete, or
update) of some IMutableRelation.IMutableRelation.delete(IChunkedOrderedIterator) when it is
flushed.IMutableRelation#insert(IChunkedIterator) when it is
flushed.IMetadataIndex.AbstractArrayBuffer, but this class is more tightly
coupled to the AbstractTripleStore.Statements into
BigdataStatements, including resolving term identifiers (or adding
entries to the lexicon for unknown terms) as required.Statements into an RDF database.StatementPatternNodes.AbstractStatisticsCollectorExecutorService
or to the ConcurrencyManager IFF the task was submitted to a
DataService.
AbstractMasterTask
handles the protocol for startup and termination of the subtask.ConcurrencyManager.ITask interface to the AbstractTask object.AbstractTask.doTask() for
read-write transactions.LockManagerTask in order to coordinate the acquisition of locks
with the LockManager before the task can execute and to release
locks after the task has completed (whether it succeeds or fails).AbstractTask instance.ITransactionService.ITripleStore
interface that is invariant across the choice of the backing store.DefaultResourceLocator.
ITuple.Object.notify().ZooKeeper.true if the binding set satisfies the constraint.
.log extension whose name
component is shared by the name component found in
#getLogBaseName().
ZooKeeper of a watch event trigger.
FederatedQueryEngine.
URLQueryModel.eventFilters to the event.
RDFFormat.getAcceptParams(Iterable, boolean, RDFFormat), but extended
to handle TupleQueryResultFormat using the same base quality value.Set of distinct ISPOs extracted from the
source solutions.
BOpFilterBase to be applied to the elements of
the relation as they are materialized from the index.
QueryHints.ACCESS_PATH_SAMPLE_LIMIT
to ZERO (0), this query hint determines whether a SCAN + FILTER or
PARALLEL SUBQUERY (aka as-bound data set join) approach.
IAccessPath implementations.IAccessPath.
IAccessPaths read.
IAccessPaths that were eliminated by a
JoinTask.
IPredicate.Annotations#ACCESS_PATH_FILTER.
BOps using the UNION of JOINs. However, also note that
this is only used for TM and that the focus store is always local
for TM.IAccessPath (versus a subquery or temporary solution set).AST2BOpContext.accessPathSampleLimit to
ZERO (0), this determines whether a SCAN + FILTER or PARALLEL SUBQUERY
(aka as-bound data set join) approach.
IAccessPath.
ZooDefs.Ids.OPEN_ACL_UNSAFE).
IBufferAccess wrapping a direct ByteBuffer.
IBufferAccess wrapping a direct ByteBuffer.
.lock extension.
AbstractResource.getNamespace().
Lock for the named resource is available, then
Lock.lock() the Lock and return the locked Lock.
#runWithLock(ZLock).
ReentrantReadWriteLock.ReadLock for the named resource is available,
then Lock.lock() the Lock and returns the Lock.
IProgram.AbstractLocalTransactionManager.
BOpStats.unitsOut and
BOpStats.chunksOut.
BOpStats.unitsOut and BOpStats.chunksOut.
BTreeCounters object to this one.
true
iff the queue was modified as a result.
SPOAssertionBuffer.nearCapacity() the statements in the buffer
will be flushed into the backing focusStore.
Statements and stores a new BigdataStatement
instance in the internal buffer.
t1 + t2 (aka ADD).
IQueryHint.
ISolutions in an IBuffer.
ISPO.
IIndexManager to be tested when attempting to resolve
a resource identifiers.
IResourceMetadata record.
JournalMetadata record.
Token.
IPredicate.Annotations.INDEX_LOCAL_FILTER.
BNode to the TERMS index (do NOT use when told
blank node semantics apply).
Options#CMD was not specified.
JavaServiceConfiguration.Options.DEFAULT_JAVA_ARGS,
JavaServiceConfiguration.Options.CLASSPATH, JavaServiceConfiguration.Options.LOG4J, and the
ServiceConfiguration.className to the command line.
SailConnection.
IPredicate.Annotations.INDEX_LOCAL_FILTER.
Leaf.ILeafListener with this Leaf.
NotMaterializedException then just route to the
rightId (around the rest of the materialization pipeline steps).
AbstractResource.toString().
ICommitRecord whose commit timestamp is
CommitRecordIndex.Entry.commitTime.
HTreeAnnotations.DEFAULT_ADDRESS_BITS
).
IndexMetadata record.
null.
JiniServiceConfiguration.Options.JINI_OPTIONS.
OneShotInstrument.
DistributedJoinTask will read
IBindingSet chunks.
SPORelation.insert(IChunkedOrderedIterator)
VocabularyDecls using
BaseVocabulary.addDecl(VocabularyDecl).
DerivedNumericsExtension.
Watcher which will receive WatchedEvents until it
is removed.
EdgeSample.outputCount as adjusted for a variety of edge conditions).
ITupleCursor to a
new key using {@link ITupleCursor#seek(byte[]).
ITupleCursor to another key
after it visits some element.AbstractTask.doTask().
IRemoteExecutors on
which that aggregator will execute.
ServicesTemplate describing the types of services and the
minimum #of services for aggregating asynchronous index writes
performed by the clients.
IRangeQuery.KEYS, IRangeQuery.VALS, IRangeQuery.DELETED].
IJoinNexus.ELEMENT and IJoinNexus.BINDINGS and IJoinNexus.RULE.
Long.MAX_VALUE).
HierarchicalZNodeWatcherFlags.EXISTS, HierarchicalZNodeWatcherFlags.DATA, HierarchicalZNodeWatcherFlags.CHILDREN].
true iff ALL GRAPHS should be effected by this
operation.
true iff ALL SOLUTION SETS should be effected by this
operation.
ByteBuffer slices on which the
application may write data.
IMemoryManager.allocate(ByteBuffer, boolean).
AllocationContext is used to maintain a handle on allocations
made within some specific environment (context).ByteBuffers.true iff a service may be instantiated on this
host.
false) added only to pass the Sesame
test suites.
BOp.Annotations.BOP_ID of
the ancestor in the operator tree which serves as the alternative
sink for binding sets (default is no alternative sink).
null, either enable or disable the analytic
query package for the request.
true, enables all query hints pertaining to analytic
query patterns.
IAnalyzerFactory class which will be used to
obtain analyzers when tokenizing documents and queries (default
).
x AND y.t1 AND t2 (aka EQ).
x AND y.BOps (non-recursive).
true iff the annotations of this BOp and the
other BOp are equals.
KeyBuilder.Options.COLLATOR
and appends the resulting sort key to the buffer (without a trailing nul
byte).
unsigned value.
unsigned values.
unsigned values.
Double.doubleToLongBits(double),
converting that values into a twos-complement number and then appending
the bytes in big-endian order into the key buffer.
Float.floatToIntBits(float)
converting that values into a twos-complement number and then appending
the bytes in big-endian order into the key buffer.
UUID.compareTo(UUID)).
BigInteger into an unsigned byte[] and append it into
the key buffer.
BigDecimal into an unsigned byte[] and append it into
the key buffer.
BigDecimal into an unsigned byte[] and append it into
the key buffer.
KeyBuilder.
ISimpleBTree.contains(byte[]).
ISimpleBTree#insert(Object, Object)
true unless overridden, meaning the
GlobalAnnotations are required for this value expression
(certain boolean value expressions do not require them).
String[] that will
be included in the command line before any service specific command
line arguments when a command is executed to start a new service
instance.
ArrayAccessPath.getPredicate() or the
ArrayAccessPath.getKeyOrder() and those methods will throw an
UnsupportedOperationException if invoked.
ArrayAccessPath.getPredicate() and ArrayAccessPath.getKeyOrder() and methods
will throw an UnsupportedOperationException if the corresponding
argument is null.
Striterator.ByteBuffer between the
position and the limit.
ByteBuffer (does NOT copy
the data).
IGPO.asClass( Class
theClassOrInterface ) implementations.
IGPO interface and is primarily used to peel off a
skin and gain access to implementation specific methods on the
IGPO implementation object.
ICloseableIterator.
IV for the Value.
IV for the Value.
null, the IVariable which will be bound
to true iff there is at least one solution for the
subquery.
null, the IVariable which will be bound to
true iff there is at least one solution for a
JoinTypeEnum.Exists hash join.
Literal for the IV.
Map.
LinkedHashMap is returned to reduce the overhead with
iterators while preserving the ordering imposed by TPS.tuples.
BTree.
HTree.
ByteBuffer containing the
serialized representation of the IndexSegmentCheckpoint record.
#first(boolean),
#last(boolean), or AbstractBTreeTupleCursor.seek(byte[]) is used to position the
cursor.
m is the branching factor and a node is understood
to be a non-leaf node in the tree.
Quorum.getClient() is
the quorum leader.
true once ResultSet.init(int) has been called and until
#done(byte[]) is called.
AbstractTask.aborted is
false).
StoreManager StoreManager.isOpen() and is NOT
StoreManager.isStarting() (the test itself is NOT atomic).
unsigned byte[]s in the logical byte[][]
are in a total order.
ITx.UNISOLATED.
IllegalStateException
unless they are invoked on the ITx.UNISOLATED Name2Addr
instance.
BigdataValue for a single
write operation when an IDuplicateRemover was applied.IPredicates.PipelineOps.TermNodes.FilterNodes which will run as "join filters" to
StatementPatternNodes.BigdataValues in the AST which are
associated with a mock IV.IBindingSet[].ConstructNode.ProjectionNode for a CONSTRUCT or DESCRIBE query.ASTContainer provides access to the original SPARQL
query, the query model, the query plan, etc.
ASTContainer
IGroupMemberNode within a
JoinGroupNode in the right order with respect to the other types.ASTQueryContainer and
ASTUpdateContainerStatementPatternNodes.IGroupMemberNode within a
JoinGroupNode in the right order w.r.t.BD.SEARCH and related magic predicates into a
ServiceNode which will invoke the bigdata search engine.ServiceNodes
into a named subquery.AST2BOpUtility#toVE(String, IValueExpressionNode).SubqueryRoots into named subqueries when appropriate.DefaultEvaluationPlan2.ProjectionNode with a wild card into the set of
variables visible to the QueryBase having that projection.Value for the IV.
LiteralExtensionIV.
AbstractInlineExtensionIV.
IV type is not 100%
inline.
XSDLongIV delegate (which represents
milliseconds since the epoch) to create a an XMLGregorianCalendar
object (GMT timezone).
XSDIntegerIV delegate to create a
datatype literal value with the appropriate datatype.
ILexiconConfiguration which has specific knowledge
of how to generate an RDF value from this general purpose extension IV.
ILexiconConfiguration which has specific knowledge
of how to generate an RDF value from this general purpose extension IV.
BigdataValue and cache it on a private field.
Value into a BigdataValue.
Resources.
URIs.
Literals.
BNodes.
IV defined by this vocabulary.
Value for that IV iff the IV is
declared in the Vocabulary.
CounterSets and for
each CounterSet writes the current value of each Counter.
AbstractCounterSet.asXML(OutputStream, String, Pattern) but does not write out
the header declaring the encoding.
ICounterSet as XML on a string and returns that
string.
true the client writes will use the asynchronous
API.
BlockingBuffer.
IndexSegment from the writes buffered on the prior
journal.ITupleIterator reading directly on an IIndex
backing a SparseRowStore into an ITupleIterator visiting
logical ITPS rows.Schema and
primary key.CounterSet as a child of this node.
SparseRowStore.SparseRowStore.WriteExecutorService as that is the only service where tasks
must acquire locks in order to execute).
IQueueCounters.IThreadPoolExecutorTaskCounters.AverageServiceTime but is broken out
here as a detail).
WriteExecutorService to coordinate the start and end of
tasks and the group commit.
Futures.
JoinTask completed successfully.
Future.
JoinTaskFactoryTask Futures.
ServiceRegistrar to be discovered.
IDataService.
MappedRDFFileLoadTask.call() has fully initialized the instance of this
class running on the IRemoteExecutor.
true iff the StoreManager is running.
IDataServices.
IMetadataService and the specified
minimum #of IDataServices.
JiniClientConfig and of the LookupLocators specified
in the JiniClientConfig which are locators for the local
host.
ZooKeeper to be ZooKeeper.States#CONNECTED, but
not more than the specified timeout.
Axioms as configured for the database.
Axioms model that will be used (default
).
true. The backchainer is only run for
normal predicates in triples mode at this time. If it is to
be layer, it should be layered as an annotation. See
https://sourceforge.net/apps/trac/bigdata/ticket/231.
IAccessPath that backchains certain inferences.BackchainTypeResourceIterator.PushbackFilter.BOp.Annotations.BOP_ID is not an
Integer.PipelineOp.Annotations#CONDITIONAL_GROUP is
not an Integer.ServiceConfiguration and if necessary makes an adjustment to the
#of logical services that are running.
Banner class.ParseOp.Annotations.SOURCE_URI).
AbstractTripleStore.create().
DistributedTransactionService.dataDir containing images
of the DistributedTransactionService.commitTimeIndex.
FileChannel.
Vocabulary implementations.AbstractTripleStore.create().
declaration classes.BatchContains procedures.BatchInsert procedures.BatchLookup procedures.IIndexProcedures.
BatchRemove procedures.BufferedConcurrentHashMap from the infinispan
project.ConcurrentHashMap and batched
updates to its access policy.LRUNexus.CacheSettings.
paused then
awaits someone to call WriteExecutorService.resume().
AbstractTask.doTask()
ZLock for the TaskMaster.JobState.
true if this path begins with the given path.
true if this path begins with the given path.
Deflater.BEST_COMPRESSION.
Deflater.BEST_SPEED.
SPARQLParser class which extracts
additional information required by bigdata and associates it with the
ParsedQuery or ParsedUpdate.IBindingSet into an openrdf BindingSet.
ICloseableIterator IBindingSets containing
either (a) BigdataValues or (b) IVs having cached
BigdataValues into a Sesame 2 CloseableIteration visiting
Sesame 2 BindingSets containing BigdataValues.ICloseableIterator with a Sesame 2
CloseableIteration.IIndexManager.IBindingSets to RDF
BigdataValues.BNode that exposes the internal term identifier.BigdataSailFactory and BigdataRepositoryFactory.DefaultResourceLocator.
GangliaService.Literal that exposes the internal term identifier.SortedMap wrapping an IIndex.SortedMap.
ITuple instance is returned for each tuple
by many ITupleIterators there is a side-effect that invalidates
the last visited BigdataMap.Entry object.BigdataMap.entrySet().BigdataMap.Entry objects in support of BigdataMap.EntrySet.ValueFactoryImpl to
create object for resources, bNodes and literals.
RDFParserFactory for N-Triples parsers.BindingSets to bigdata
IBindingSets (this is a streaming API).ParsedQuery for API compliance with QueryParser
but DOES NOT support ANY aspect of the QueryParser API.ParsedUpdate for API compliance with QueryParser
but DOES NOT support ANY aspect of the QueryParser API.QueryServlet(s) for the same
IIndexManager.Servlets which interact with the bigdata RDF
data and/or SPARQL query layers.IIndexManager by
interpreting the configuration parameters in the ServletContext.ValueFactoryImpl to
create RDF model objects.
RDFParserFactory for RDF/XML parsers.RDFWriterFactory for RDF/XML writers with the bigdata specific
extensions.RepositoryFactory that creates BigdataSailRepositorys
based on RDF configuration data.Resource that exposes the internal term identifier.2.x integration.AbstractTripleStore
instance.
SailConnection.SailConnection for the database.
SailFactory that creates BigdataSails based on RDF
configuration data.IVs.SortedSet backed by a B+Tree.ISolutions to RDF
BigdataValues.BigdataValueFactory
BigdataStatements.ISolutions to RDF
BigdataValues.URI that exposes the internal term identifier.Values stored within a IRawTripleStore.BigdataValues and BigdataStatements.BigdataValues into an ordering determined by their assigned
term identifiers.BigdataValue implementations.BigdataValues.BigdataValue (batch API).Values
in a BindingSet into the BigdataValues used internally by
bigdata.Value
objects.op(t1,t2)
IBindingSet to the
destination IBindingSet.
#bind(IPredicate, Object, IBindingSet)
IBindingSet[] to be used instead
of the default source.
IJoinNexus.newSolution(IRule, IBindingSet) should
clone the IBindingSet and make it available via
ISolution.getBindingSet().
JoinTasks.
IBindingSet chunks written onto the next join
dimension (aka the #of solutions written iff this is the last join
dimension in the evaluation order).
JoinTasks.
IBindingSets.IBindingSets written onto the next join dimension
(aka the #of solutions written iff this is the last join dimension).
Value when the value is not being
inlined, but primarily used with large RDF Values.BlobIVs.
Value
will be inserted into the LexiconKeyOrder.BLOBS index rather
than the LexiconKeyOrder.TERM2ID and
LexiconKeyOrder.ID2TERM indices (default
"256").
BigdataValue.Values in the LexiconKeyOrder.BLOBS index
in BlobIV order (efficient index scan).
Values into the
{termCode,hash(Value),counter}:Value index, assigning IVs to
Values as a side-effect.IVs and provides
efficient serialization for communication of those data to the client.BlockingQueue.
BufferAnnotations to provision the
BlockingBuffer and to track the BOpStats as chunks are added
to the buffer.maxN := n * 2.
true iff the SPO index will maintain a bloom filter.
AbstractBTree and which allows the caller to specify the expected
number of index entries, the desired error rate for the filter at that #of
index entries, and the maximum error rate before the bloom filter will be
disabled.Values
when processing a document (asynchronous writes only).
OR.Literal.booleanValue().
Literal.booleanValue().
Literal.booleanValue().
Literal.booleanValue().
BOp.
BOps.BOp.ITupleIterators.IServicesManagerService.sighup(boolean,boolean) method or
ILoadBalancerService.sighup() method to either local or
all discovered IServicesManagerServices
or ILoadBalancerServices in federation to which it
connects.http://www4.wiwiss.fu-berlin.de/bizer/bsbm/v01/vocabulary/USD
datatype, which is treated as xsd:float.Vocabulary covering the ontologies used by LUBM.AbstractTripleStore.create().
BTree and any derived subclasses.
Leafs.NodeSerializer.Nodes in the BTree.LeafCursor.BTree.
BTree that will be used to
re-load the index.
IndexSegment (default
).
BTree.BTree backed by a Journal.AbstractBTree.ByteBuffer.
Values and Statements emitted by
the RDF parser (the value is supplied by the ctor).
AbstractSubtask.master is writing.
ByteBuffer instances
allocated and managed by the DirectBufferPool (DirectBufferPool.Options.DEFAULT_BUFFER_CAPACITY).
StatementBuffer (default is "100000"
statements).
Options.DEFAULT_BUFFER_MODE).
BlockingBuffer as used by various kinds of operators.IBlockingBuffer#add() if the buffer is closed.IndexSegmentStore.buf_nodes.
true the generated nodes will be fully buffered in RAM.
WriteCache's backing ByteBuffer
of the start of the record.
BOp in some
running query is available.
BOp in some
running query is available.
IndexSegment and which contains more
interesting information about the build.
IndexSegment from an index partition.
CompactingMergeTask.BuildResults for each output split.
StatementEnum and/or statement identifier (SID)
for ISPOs using the given statement IIndex.ISPOs that are present in the database.
TempTripleStore.
ISPOs either present or NOT present in the target
statement IIndex.ISPO objects for whether they are
"present" or "not present" in the database, depending on the value of the
supplied boolean variable (batch API).
SPO objects for whether
they are "present" or "not present" in the database, depending on the
value of the supplied boolean variable (batch api).
ByteBuffer as a read-only BitVector.ByteBuffer.ByteBuffer.BigInteger value.
BigDecimal value.
IV.
StoreManager after they became release free.
StoreManager.
Literal.byteValue().
Literal.byteValue().
Literal.byteValue().
#NULL.
IRawStore cache instances (current value).
TxDag.getOrder() is
cached.
BigdataValue on the IV (create a cross linkage).String value that uniquely identifies the cage
(within a given zone) that contains the rack in which
the associated service is executing.
Literal.calendarValue().
Literal.calendarValue().
Literal.calendarValue().
IndexSegment given the parameters specified to the
constructor.
BigdataZooDefs.CONFIG znode.
BigdataZooDefs.LOCKS_CREATE_PHYSICAL_SERVICE
znode.
ZLock and then invokes
#runWithZLock(), which will verify the constraints and
attempt to start the service.
ZLock on #zpath and then maintains a
balance between: (a) the ServiceConfiguration state for a service
type; (b) the #of logical service instances for that service type; and
(c) the #of physical service instances for any logical service instance
for that service type.