|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
HistoryTable.a.
AbstractJournal.commitNow(long)()
and also discards the unisolated (aka live) btree objects, reloading them
from the current ICommitRecord on demand.
IAccessPath implementations.IElementFilter constraint with
ITupleFilter so that the IElementFilter can be evaluated
close to the data by an ITupleIterator.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.IResourceLocators with caching.LookupCache to
reduce round trips to the discovered ServiceRegistrars for a
specific class of services.IChunkedIterator and asynchronously resolves chunks.ResultSet at a time.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.LoadBalancerService.EmbeddedFederation.IBigdataFederation implementations.ILoadBalancerService.IMapTasks accepting a filename as the
"key" and the file contents as the "value".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 Response by default.IIndex like objects.IJobAndTaskService.MapService or the
ReduceService.AbstractJobAndTaskService.AbstractJobAndTaskService(Properties)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.IMapTasks.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.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.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).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.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..log extension whose name
component is shared by the name component found in
#getLogBaseName().
URLQueryModel.eventFilters to the event.
IAccessPaths read.
IAccessPaths that were eliminated by a
JoinTask.
IPredicate constraint in two different databases (this is used for
truth maintenance when reading on the union of a focus store and the
database).ZooDefs.Ids.OPEN_ACL_UNSAFE).
ByteBuffer.
.lock extension.
AbstractResource.getNamespace().
Lock for the named resource is available, then
Lock.lock() the Lock and return the locked Lock.
ServiceConfigurationZNodeMonitorTask.runWithLock(ZLock)
ReentrantReadWriteLock.ReadLock for the named resource is available,
then Lock.lock() the Lock and returns the Lock.
IProgram.AbstractLocalTransactionManager.
BTreeCounters object to this one.
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.
ISolutions in an IBuffer.
ISPO.
Value into the internal collection.
IIndexManager to be tested when attempting to resolve
a resource identifiers.
String to the
IResourceLocator for the identified IRelation.
IResourceMetadata record.
JournalMetadata record.
Token.
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.
Leaf.ILeafListener with this Leaf.
AbstractResource.toString().
ICommitRecord whose commit timestamp is
CommitRecordIndex.Entry.commitTime.
IRawStore
such that each store may be provisioned for a different split
between the bits dedicated to the offset and the bits dedicated
to the length of the data record. Only Addr.toLong(int, int),
Addr.getOffset(long), and Addr.getByteCount(long) will
need to become instance methods. The metadata required to recover
the provisioned bit split must be stored in the root block of a
persistence store so that it may be recovered without record to
decoding an Addr. (This is also going to cause a lot of
javadoc comments to refer to the "Addr" interface, which will be
the base interface for IRawStore and that will be
confusing and should be cleaned up.)
Other consequences are that offset and nextOffset are always long
integers and that packing and unpacking of addresses requires
knowledge of the #offset bits (so SerializerUtil should
not be used for those cases). This change to serialization also
effects how btree nodes and leaves are stored.
NodeSerializer by the IRabaCoderIndexMetadata record.
AbstractFederation.shutdown().
JiniServiceConfiguration.Options.JINI_OPTIONS.
OneShotInstrument.
DistributedJoinTask will read
IBindingSet chunks.
SPORelation.insert(IChunkedOrderedIterator)
Values declared by this class.
Watcher which will receive WatchedEvents until it
is removed.
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 a service may be instantiated on this
host.
KeyBuilder.Options.COLLATOR
and appends the resulting sort key to the buffer (without a trailing nul
byte).
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.
JiniServicesHelper.CONFIG_STANDALONE configuration file and a configuration
file specified by the caller, so leave some whitespace at the top or
bottom of one of the files.
KeyBuilder.
ISimpleBTree.contains(byte[]).
ISimpleBTree#insert(Object, Object)
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.
IBindingSet backed by an dense array (no gaps).null and that no
variables are duplicated).
IPredicate in which zero or more variables have
been bound to constants using the given IBindingSet.
Predicate.toArray(IBindingSet).
ByteBuffer between the
position and the limit.
ByteBuffer (does NOT copy
the data).
LinkedHashMap is returned to reduce the overhead with
iterators while preserving the ordering imposed by TPS.tuples.
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.
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.
Value into a BigdataValue.
Resources.
URIs.
Literals.
BNodes.
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.
ConcurrentDataLoader.loadService to be "complete" AND for the
#futuresQueue to be empty.
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
).
IAccessPath that backchains certain inferences.BackchainTypeResourceIterator.PushbackFilter.ServiceConfiguration and if necessary makes an adjustment to the
#of logical services that are running.
Banner class.AbstractTripleStore.create().
DistributedTransactionService.dataDir containing images
of the DistributedTransactionService.commitTimeIndex.
Vocabulary implementations.AbstractTripleStore.create().
BatchContains procedures.BatchInsert procedures.BatchLookup procedures.IIndexProcedures.
BatchRemove procedures.paused then
awaits someone to call WriteExecutorService.resume().
AbstractTask.doTask()
ZLock for the TaskMaster.JobState.
Deflater.BEST_COMPRESSION.
Deflater.BEST_SPEED.
ICloseableIterator IBindingSets containing
BigdataValues with a Sesame 2 CloseableIteration visiting
Sesame 2 BindingSets.ICloseableIterator with a Sesame 2
CloseableIteration.BNode that exposes the internal term identifier.StatementPatterns to
influence the cardinality.TupleExprs onto native Rules and
to evaluate magic predicates for full text search, etc.DefaultResourceLocator.
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.Resource that exposes the internal term identifier.2.x integration.SailConnection.SailConnection for the database.
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.BigdataValues.BigdataValue (batch API).Value
objects.SPOAccessPath where the context position has been
bound to the specified constant.
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).
BlockingQueue.
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).
Values
when processing a document (asynchronous writes only).
OR.IServicesManagerService#sighup() method to
all discovered IServicesManagerServices in federation to which it
connects.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
).
AbstractBTree.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).
ByteBuffer instances
allocated and managed by the DirectBufferPool (BufferedDiskStrategy.Options.DEFAULT_BUFFER_CAPACITY).
StatementBuffer (default is 100k statements).
Options.DEFAULT_BUFFER_MODE).
IBlockingBuffer#add() if the buffer is closed.BufferedDiskStrategy.IndexSegmentStore.buf_nodes.
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).
1024 bytes.
ByteBuffer as a read-only BitVector.ByteBuffer.ByteBuffer.StoreManager after they became release free.
StoreManager.
ISPO.NULL.
IRawStore cache instances (current value).
TxDag.getOrder() is
cached.