public interface IIndexStore
Note: Historically, this was class was named for the ability to manage index objects in both local and distributed contexts. However, the introduction of GIST support has necessitated a refactoring of the interfaces and the name of this interface no longer reflects its function.
Modifier and Type | Method and Description |
---|---|
ScheduledFuture<?> |
addScheduledTask(Runnable task,
long initialDelay,
long delay,
TimeUnit unit)
Adds a task which will run until canceled, until it throws an exception,
or until the service is shutdown.
|
void |
destroy()
Destroy the
IIndexStore . |
boolean |
getCollectPlatformStatistics()
true iff performance counters will be collected for the
platform on which the client is running. |
boolean |
getCollectQueueStatistics()
true iff statistics will be collected for work queues. |
ExecutorService |
getExecutorService()
A
ExecutorService that may be used to parallelize operations. |
BigdataFileSystem |
getGlobalFileSystem()
Return the global file system used to store block-structured files and
their metadata and as a source and sink for map/reduce processing.
|
SparseRowStore |
getGlobalRowStore()
Return an unisolated view of the global
SparseRowStore used to
store named property sets. |
SparseRowStore |
getGlobalRowStore(long timestamp)
Return a view of the global
SparseRowStore used to store named
property sets as of the specified timestamp. |
int |
getHttpdPort()
The port on which the optional httpd service will be run.
|
long |
getLastCommitTime()
The database wide timestamp of the most recent commit on the store or 0L
iff there have been no commits.
|
IResourceLocator |
getResourceLocator()
Return the default locator for resources that are logical index
containers (relations and relation containers).
|
IResourceLockService |
getResourceLockService()
The service that may be used to acquire synchronous distributed locks
without deadlock detection.
|
TemporaryStore |
getTempStore()
A factory for
TemporaryStore s. |
SparseRowStore getGlobalRowStore()
SparseRowStore
used to
store named property sets.GlobalRowStoreSchema
SparseRowStore getGlobalRowStore(long timestamp)
SparseRowStore
used to store named
property sets as of the specified timestamp.
The SparseRowStore
only permits ITx.UNISOLATED
writes, so
you MUST specify ITx.UNISOLATED
as the timestamp if you intend to
write on the global row store!
You can request the most recent committed state of the global row store
by specifying ITx.READ_COMMITTED
.
timestamp
- The timestamp of the view.null
if no view
exists as of that timestamp.BigdataFileSystem getGlobalFileSystem()
BigdataFileSystem
TemporaryStore getTempStore()
TemporaryStore
s. TemporaryStore
s are
thread-safe and may be used by multiple processes at once. Old
TemporaryStore
s are eventually retired by the factory and their
storage is reclaimed once they are finalized (after they are no longer in
use by any process). The decision to retire a TemporaryStore
is
either made implicitly, when it is no longer weakly reachable, or
explicitly, when it has grown large enough that no new processes should
begin using that TemporaryStore
. In the latter case, the
TemporaryStore
will remain available to the process(es) using it
and a new TemporaryStore
will be allocated and made available to
the caller.
It is important that processes do not hold a hard reference to a
TemporaryStore
beyond the end of the process as that will prevent
the TemporaryStore
from being finalized. Holding reference to an
AbstractBTree
created on a TemporaryStore
is equivalent
to holding a hard reference to the TemporaryStore
itself since
the AbstractBTree
holds onto the backing IRawStore
using
a hard reference.
TemporaryStore
.IResourceLocator getResourceLocator()
ExecutorService getExecutorService()
ExecutorService
that may be used to parallelize operations.
This service is automatically used when materializing located resources.
While the service does not impose concurrency controls, tasks run on this
service may submit operations to a ConcurrencyManager
.ScheduledFuture<?> addScheduledTask(Runnable task, long initialDelay, long delay, TimeUnit unit)
task
- The task.initialDelay
- The initial delay.delay
- The delay between invocations.unit
- The units for the delay parameters.ScheduledFuture
for that task.boolean getCollectPlatformStatistics()
true
iff performance counters will be collected for the
platform on which the client is running.boolean getCollectQueueStatistics()
true
iff statistics will be collected for work queues.int getHttpdPort()
IResourceLockService getResourceLockService()
long getLastCommitTime()
This method is useful if you plan to issue a series of read-consistent requests against the most current commit point of the database.
IRootBlockView.getLastCommitTime()
void destroy()
IIndexStore
.Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.