Package | Description |
---|---|
com.bigdata.bfs |
This package provides a scale-out content repository (aka distributed file
system) suitable as the backend for a REST-ful service using the bigdata
architecture.
|
com.bigdata.bop |
This package provides an API for query operators.
|
com.bigdata.bop.ap | |
com.bigdata.bop.engine | |
com.bigdata.bop.fed | |
com.bigdata.btree |
The
BTree is a scalable B+-Tree with copy-on-write
semantics mapping variable length unsigned byte[] keys to variable
length byte[] values (null values are allowed). |
com.bigdata.config | |
com.bigdata.counters.ganglia | |
com.bigdata.gom |
This module provides a scalable client / server architecture for graph data
management based on the principles of REST, Topic Maps, and RDF.
|
com.bigdata.ha |
This package extends
com.bigdata.quorum to define local and
Remote interfaces for highly available services. |
com.bigdata.journal |
The journal is an append-only persistence capable data structure
supporting atomic commit, named indices, and transactions.
|
com.bigdata.rdf.graph.impl.bd | |
com.bigdata.rdf.inf |
This package provides an eager closure inference engine for most of the RDF and
RDFS entailments and can be used to realize entailments for owl:sameAs, owl:equivilentClass,
and owl:equivilentProperty.
|
com.bigdata.rdf.lexicon | |
com.bigdata.rdf.load |
Support for concurrent loading of RDF data across one or more clients from
a variety of input sources.
|
com.bigdata.rdf.rules | |
com.bigdata.rdf.sail |
This package contains the SAIL that allow bigdata to be used as a backend for
the Sesame 2.x platform.
|
com.bigdata.rdf.sail.tck | |
com.bigdata.rdf.sail.webapp | |
com.bigdata.rdf.sail.webapp.lbs | |
com.bigdata.rdf.sail.webapp.lbs.policy.counters | |
com.bigdata.rdf.sail.webapp.lbs.policy.ganglia | |
com.bigdata.rdf.spo |
This package defines a statement model using long term identifiers rather than
RDF Value objects.
|
com.bigdata.rdf.store |
This package provides several realizations of an RDF database using the bigdata
architecture, including one suitable for temporary data, one suitable for local
processing (single host), and one designed for scale-out on commodity hardware.
|
com.bigdata.rdf.task |
Abstraction layer for task-based concurrency at the triple store layer.
|
com.bigdata.rdf.util | |
com.bigdata.relation |
This package includes an abstraction layer for relations.
|
com.bigdata.relation.accesspath |
This package includes an abstraction layer for efficient access paths, including
chunked iterators, blocking buffers, and an abstraction corresponding to the natural
order of an index.
|
com.bigdata.relation.locator |
Abstraction layer for identifying relations and relation containers in much
the same manner that indices are identified (unique name and timestamp).
|
com.bigdata.relation.rule.eval |
This package supports rule evaluation.
|
com.bigdata.resources |
This package provides the logic to managed the live journal and the
historical journals and index segments for a
DataService . |
com.bigdata.search |
This package provides full text indexing and search.
|
com.bigdata.service |
This package provides implementations of bigdata services (metadata
service, data service, transaction manager service.
|
com.bigdata.sparse |
This package provides support for treating normal B+Trees using a
"sparse row store" pattern and can be applied to both local B+Trees
and scale-out indices.
|
com.bigdata.stream | |
com.bigdata.striterator |
Streaming iterator patterns based on Martyn Cutcher's striterator design
but supporting generics and with extensions for closable, chunked, and
ordered streaming iterators.
|
org.openrdf.query.parser.sparql |
Constructor and Description |
---|
BigdataFileSystem(IIndexManager indexManager,
String namespace,
Long timestamp,
Properties properties)
Ctor specified by
DefaultResourceLocator . |
GlobalFileSystemHelper(IIndexManager indexManager) |
Modifier and Type | Method and Description |
---|---|
IIndexManager |
BOpContextBase.getIndexManager()
The local
IIndexManager . |
Modifier and Type | Method and Description |
---|---|
static <E> BOpContext<E> |
BOpContext.newMock(IRunningQuery runningQuery,
IBigdataFederation<?> fed,
IIndexManager localIndexManager,
int partitionId,
BOpStats stats,
PipelineOp op,
boolean lastInvocation,
ICloseableIterator<E[]> source,
IBlockingBuffer<E[]> sink,
IBlockingBuffer<E[]> sink2)
Test suite helper.
|
Constructor and Description |
---|
BOpContextBase(IBigdataFederation<?> fed,
IIndexManager localIndexManager)
Core constructor.
|
Modifier and Type | Method and Description |
---|---|
protected IJoinNexus |
MockJoinNexusFactory.newJoinNexus(IIndexManager indexManager) |
Constructor and Description |
---|
R(IIndexManager indexManager,
String namespace,
Long timestamp,
Properties properties) |
Modifier and Type | Method and Description |
---|---|
IIndexManager |
QueryEngine.getIndexManager()
The local index manager, which provides direct access to local
BTree and IndexSegment objects. |
IIndexManager |
MockRunningQuery.getLocalIndexManager() |
IIndexManager |
AbstractRunningQuery.getLocalIndexManager() |
IIndexManager |
IRunningQuery.getLocalIndexManager()
The local
IIndexManager . |
Constructor and Description |
---|
MockRunningQuery(IBigdataFederation<?> fed,
IIndexManager indexManager)
Note: This constructor DOES NOT check its arguments so unit tests may be
written with the minimum dependencies
|
MockRunningQuery(IBigdataFederation<?> fed,
IIndexManager indexManager,
IQueryContext queryContext) |
QueryEngine(IIndexManager localIndexManager) |
Modifier and Type | Method and Description |
---|---|
QueryEngine |
QueryEngineFactoryBase.getQueryController(IIndexManager indexManager) |
QueryEngine |
IQueryEngineFactory.getQueryController(IIndexManager indexManager)
Singleton factory for standalone or scale-out.
|
Constructor and Description |
---|
FederatedQueryEngine(UUID thisService,
IBigdataFederation<?> fed,
IIndexManager indexManager,
ManagedResourceService resourceService)
Constructor used on a non-
DataService node to expose a query
controller. |
Modifier and Type | Method and Description |
---|---|
protected String |
IndexMetadata.getProperty(IIndexManager indexManager,
Properties properties,
String namespace,
String globalName,
String defaultValue) |
protected <E> E |
IndexMetadata.getProperty(IIndexManager indexManager,
Properties properties,
String namespace,
String globalName,
String defaultValue,
IValidator<E> validator) |
Constructor and Description |
---|
HTreeIndexMetadata(IIndexManager indexManager,
Properties properties,
String namespace,
UUID indexUUID)
Constructor used to configure a new named B+Tree.
|
IndexMetadata(IIndexManager indexManager,
Properties properties,
String namespace,
UUID indexUUID,
IndexTypeEnum indexType)
Constructor used to configure a new named B+Tree.
|
Modifier and Type | Method and Description |
---|---|
static String |
Configuration.getProperty(IIndexManager indexManagerIsIgnored,
Properties properties,
String namespace,
String propertyName,
String defaultValue)
Return the value for property, which may be the default value, a global
override, or a namespace override.
|
static <E> E |
Configuration.getProperty(IIndexManager indexManager,
Properties properties,
String namespace,
String globalName,
String defaultValue,
IValidator<E> validator)
Variant converts to the specified generic type and validates the value.
|
static NV |
Configuration.getProperty2(IIndexManager indexManagerIsIgnored,
Properties properties,
String namespace,
String globalName,
String defaultValue)
Variant returns both the name under which the value was discovered and
the value.
|
protected static UUID |
Configuration.resolveDataService(IIndexManager indexManager,
String val)
Resolve the value to a
DataService UUID . |
Constructor and Description |
---|
QueryEngineMetricsCollector(IIndexManager indexManager,
AbstractStatisticsCollector statisticsCollector) |
Modifier and Type | Field and Description |
---|---|
protected IIndexManager |
RemoteGOMTestCase.m_indexManager |
Modifier and Type | Interface and Description |
---|---|
interface |
IHAJournal
Convenience interface created in BLZG-1370 to factor out bigdata-jini
artifact dependencies.
|
Modifier and Type | Method and Description |
---|---|
IIndexManager |
IndexManagerCallable.getIndexManager() |
IIndexManager |
IIndexManagerCallable.getIndexManager()
Return the
IIndexManager . |
Modifier and Type | Method and Description |
---|---|
void |
IndexManagerCallable.setIndexManager(IIndexManager indexManager) |
void |
IIndexManagerCallable.setIndexManager(IIndexManager indexManager)
Invoked before the task is executed to provide a reference to the
IIndexManager on which it is executing. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractIndexManagerTestCase<S extends IIndexManager> |
interface |
IPlugIn<M extends IIndexManager,S>
Interface for a "plug in" that can be registered with a
Journal . |
class |
ProxyTestCase<S extends IIndexManager>
This class provides proxy delegation logic for abstract methods declared by
AbstractJournalTestCase and is used to extend the set of tests that will be
applied to all implementations of the generic object model Java API. |
Modifier and Type | Interface and Description |
---|---|
interface |
IBTreeManager
|
interface |
IJournal
An persistence capable data structure supporting atomic commit, scalable
named indices, and transactions.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractJournal
The journal is a persistence capable data structure supporting atomic commit,
named indices, and full transactions.
|
class |
Journal
Concrete implementation suitable for a local and unpartitioned database.
|
class |
JournalDelegate
IJournal delegation pattern. |
class |
TemporaryStore
A temporary store that supports named indices but no concurrency controls.
|
Constructor and Description |
---|
BigdataGASEngine.BigdataGraphAccessor(IIndexManager indexManager)
Obtain a view of the default KB instance as of the last commit time on
the database.
|
BigdataGASEngine.BigdataGraphAccessor(IIndexManager indexManager,
String namespace,
long timestamp) |
BigdataGASEngine(IIndexManager indexManager,
int nthreads) |
Constructor and Description |
---|
JustificationIterator(IIndexManager indexManager,
IIndex ndx,
int capacity)
Deprecated.
Create an iterator reading from the justifications index.
|
Modifier and Type | Method and Description |
---|---|
static BigdataSubjectCentricFullTextIndex |
BigdataSubjectCentricFullTextIndex.getInstance(IIndexManager indexManager,
String namespace,
Long timestamp,
Properties properties) |
static BigdataValueCentricFullTextIndex |
BigdataValueCentricFullTextIndex.getInstance(IIndexManager indexManager,
String namespace,
Long timestamp,
Properties properties) |
IAccessPath<BigdataValue> |
LexiconRelation.newAccessPath(IIndexManager localIndexManager,
IPredicate<BigdataValue> predicate,
IKeyOrder<BigdataValue> keyOrder)
Necessary for lexicon joins, which are injected into query plans as
necessary by the query planner.
|
Constructor and Description |
---|
BigdataSubjectCentricFullTextIndex(IIndexManager indexManager,
String namespace,
Long timestamp,
Properties properties) |
BigdataValueCentricFullTextIndex(IIndexManager indexManager,
String namespace,
Long timestamp,
Properties properties) |
LexiconRelation(AbstractTripleStore container,
IIndexManager indexManager,
String namespace,
Long timestamp,
Properties properties) |
LexiconRelation(IIndexManager indexManager,
String namespace,
Long timestamp,
Properties properties)
Note: The term:id and id:term indices MUST use unisolated write operation
to ensure consistency without write-write conflicts.
|
Modifier and Type | Method and Description |
---|---|
void |
AssignedSplits.registerIndex(IIndexManager indexManager,
IndexMetadata indexMetadata)
Register the index against the federation using the index partitions and
data services described by this instance.
|
Modifier and Type | Method and Description |
---|---|
protected IJoinNexus |
RDFJoinNexusFactory.newJoinNexus(IIndexManager indexManager) |
Constructor and Description |
---|
RDFJoinNexus(RDFJoinNexusFactory joinNexusFactory,
IIndexManager indexManager) |
Modifier and Type | Method and Description |
---|---|
IIndexManager |
BigdataBaseContext.getIndexManager() |
IIndexManager |
BigdataSail.getIndexManager()
The index manager associated with the database (when there is a focus
store and a main database, then this is the focus store index manager).
|
Modifier and Type | Method and Description |
---|---|
protected Properties |
BigdataSailHelper.getProperties(IIndexManager indexManager,
String namespace)
Deprecated.
Return the properties associated with the given namespace.
|
protected Properties |
BigdataSailHelper.setProperties(IIndexManager indexManager,
String namespace,
Properties properties)
Deprecated.
|
Constructor and Description |
---|
BigdataBaseContext(IIndexManager indexManager) |
BigdataSail(AbstractTripleStore database,
IIndexManager mainIndexManager)
Core ctor.
|
BigdataSail(String namespace,
IIndexManager indexManager)
Constructor used when the namespace and index manager are known (standard
use case).
|
BigdataSail(String namespace,
IIndexManager indexManager,
IIndexManager mainIndexManager)
Core constructor.
|
Modifier and Type | Method and Description |
---|---|
protected void |
BigdataComplexSparqlQueryTest.tearDownBackend(IIndexManager backend) |
protected void |
BigdataSPARQLUpdateTest.tearDownBackend(IIndexManager backend) |
protected void |
BigdataSparqlTest.tearDownBackend(IIndexManager backend) |
protected void |
BigdataEmbeddedFederationSparqlTest.tearDownBackend(IIndexManager backend) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractIndexManagerTestCase<S extends IIndexManager> |
class |
AbstractSimpleInsertTest<S extends IIndexManager> |
class |
AbstractTestNanoSparqlClient<S extends IIndexManager>
Proxied test suite.
|
class |
ProxyTestCase<S extends IIndexManager>
This class provides proxy delegation logic for abstract methods declared by
AbstractJournalTestCase and is used to extend the set of tests that will be
applied to all implementations of the generic object model Java API. |
class |
StressTest_REST_MultiTenancy<S extends IIndexManager>
Proxied test suite providing a stress test of the multi-tenancy API.
|
class |
StressTestConcurrentRestApiRequests<S extends IIndexManager>
Proxied test suite.
|
class |
Test_REST_ASK<S extends IIndexManager>
Proxied test suite.
|
class |
Test_REST_DELETE_BY_ACCESS_PATH<S extends IIndexManager>
Proxied test suite for the DELETE_BY_ACCESS_PATH method.
|
class |
Test_REST_DELETE_WITH_BODY<S extends IIndexManager>
Proxied test suite.
|
class |
Test_REST_DESCRIBE<S extends IIndexManager>
Proxied test suite.
|
class |
Test_REST_ESTCARD<S extends IIndexManager>
Proxied test suite for the ESTCARD method (estimated cardinality aka fast
range counts) and related operations at the
RepositoryConnection that
tunnel through to the same REST API method (getContexts(), size()). |
static class |
Test_REST_ESTCARD.ReadWriteTx<S extends IIndexManager> |
class |
Test_REST_HASSTMT<S extends IIndexManager>
Proxied test suite for the
HASSTMT REST API method. |
static class |
Test_REST_HASSTMT.ReadWriteTx<S extends IIndexManager>
Adds test coverage using read/write tx and verifies that the behavior is
correct after we delete statements (that is, it is not relying on a fast
range count for read/write tx namespaces).
|
static class |
Test_REST_HASSTMT.TruthMaintenance<S extends IIndexManager>
Test suite for the semantics of includeInferred (this requires setting up
a namespace with truth maintenance).
|
class |
Test_REST_ServiceDescription<S extends IIndexManager>
Proxied test suite.
|
class |
Test_REST_Structure<S extends IIndexManager>
Proxied test suite for bootstrap and basic structure tests for the REST API.
|
class |
Test_REST_TX_API<S extends IIndexManager>
Proxied test suite for testing the transaction management API.
|
static class |
Test_REST_TX_API.NoReadWriteTx<S extends IIndexManager>
An *extension* of the test suite that uses a namespace that is NOT
configured to support read/write transactions.
|
static class |
Test_REST_TX_API.ReadWriteTx<S extends IIndexManager>
An *extension* of the test suite that uses a namespace that is configured
to support read/write transactions.
|
class |
Test_Ticket_1207<S extends IIndexManager>
GETSTMTS test suite for includeInferred.
|
class |
Test_Ticket_1717<S extends IIndexManager>
GETSTMTS test suite for not resolved numeric IVs in Bind.
|
class |
Test_Ticket_605<S extends IIndexManager> |
class |
TestBackupServlet<S extends IIndexManager>
Proxied test suite for
DataLoaderServlet |
class |
TestBigdataSailRemoteRepository<S extends IIndexManager>
Proxied test suite for
BigdataSailRemoteRepository and
BigdataSailRemoteRepositoryConnection . |
static class |
TestBigdataSailRemoteRepository.ReadWriteTx<S extends IIndexManager>
An *extension* of the test suite that uses a namespace that is configured
to support read/write transactions.
|
class |
TestCBD731<S extends IIndexManager>
Proxied test suite.
|
class |
TestDataLoaderServlet<S extends IIndexManager>
Proxied test suite for
DataLoaderServlet |
class |
TestFederatedQuery<S extends IIndexManager>
Proxied test suite for SPARQL 1.1 Federated Query.
|
class |
TestInsertFilterFalse727<S extends IIndexManager>
Proxied test suite.
|
class |
TestMultiTenancyAPI<S extends IIndexManager>
Proxied test suite for the Multi-Tenancy API.
|
class |
TestNanoSparqlClient<S extends IIndexManager>
Proxied test suite.
|
class |
TestNanoSparqlServerWithProxyIndexManager<S extends IIndexManager>
Test suite for
RESTServlet (SPARQL end point and REST API for RDF
data). |
class |
TestNanoSparqlServerWithProxyIndexManager2<S extends IIndexManager>
A version of the test suite that is intended for local debugging and is NOT
run in CI.
|
class |
TestRDROperations<S extends IIndexManager>
Test of RDR specific data interchange and query.
|
class |
TestRebuildTextIndex<S extends IIndexManager>
Proxied test suite for rebuilding full text index.
|
class |
TestRWStoreTxBehaviors<S extends IIndexManager>
Tests that are RWStore specific.
|
class |
TestSparqlUpdate<S extends IIndexManager>
Proxied test suite.
|
class |
TestSparqlUpdateSuppressTruthMaintenance<S extends IIndexManager> |
Modifier and Type | Method and Description |
---|---|
protected IIndexManager |
BigdataServlet.getIndexManager()
The backing
IIndexManager . |
static IIndexManager |
BigdataServlet.getIndexManager(javax.servlet.ServletContext servletContext)
The backing
IIndexManager . |
Modifier and Type | Method and Description |
---|---|
HAStatusServletUtilProxy |
HAStatusServletUtilProxy.HAStatusServletUtilFactory.getInstance(IIndexManager indexManager) |
HAStatusServletUtilProxy |
HAStatusServletUtilProxy.HAStatusServletUtilFactory.getInstance(String provider,
IIndexManager indexManager) |
static org.eclipse.jetty.server.Server |
NanoSparqlServer.newInstance(int port,
IIndexManager indexManager,
Map<String,String> initParams)
Start the embedded
Server . |
static org.eclipse.jetty.server.Server |
NanoSparqlServer.newInstance(int port,
String jettyXml,
IIndexManager indexManager,
Map<String,String> initParams)
Start the embedded
Server . |
static org.eclipse.jetty.server.Server |
NanoSparqlServer.newInstance(String jettyXml,
IIndexManager indexManager,
Map<String,String> initParams)
Variant used when you already have the
IIndexManager . |
void |
AbstractDelegateRestApiTask.setIndexManager(IIndexManager indexManager) |
static junit.framework.TestSuite |
TestNanoSparqlServerWithProxyIndexManager.suite(IIndexManager indexManager,
com.bigdata.rdf.sail.webapp.TestMode testMode)
Return suite running in the given mode against the given
IIndexManager . |
static junit.framework.Test |
TestNanoSparqlServerWithProxyIndexManager2.suite(IIndexManager indexManager,
com.bigdata.rdf.sail.webapp.TestMode testMode)
Return suite running in the given mode against the given
IIndexManager . |
Constructor and Description |
---|
BigdataRDFContext(SparqlEndpointConfig config,
IIndexManager indexManager) |
HAStatusServletUtilProxy(IIndexManager indexManager) |
Modifier and Type | Method and Description |
---|---|
void |
IHAPolicyLifeCycle.init(javax.servlet.ServletConfig servletConfig,
IIndexManager indexManager)
Initialize the policy.
|
void |
AbstractLBSPolicy.init(javax.servlet.ServletConfig servletConfig,
IIndexManager indexManager) |
void |
AbstractHostLBSPolicy.init(javax.servlet.ServletConfig servletConfig,
IIndexManager indexManager) |
void |
DefaultHARequestURIRewriter.init(javax.servlet.ServletConfig servletConfig,
IIndexManager indexManager)
Initialize the policy.
|
static ServiceScore |
ServiceScore.newInstance(IIndexManager indexManager,
String contextPath,
UUID serviceUUID)
Factory for
ServiceScore instances. |
Modifier and Type | Method and Description |
---|---|
void |
CountersLBSPolicy.init(javax.servlet.ServletConfig servletConfig,
IIndexManager indexManager) |
Modifier and Type | Method and Description |
---|---|
void |
GangliaLBSPolicy.init(javax.servlet.ServletConfig servletConfig,
IIndexManager indexManager) |
Modifier and Type | Method and Description |
---|---|
IAccessPath<ISPO> |
SPORelation.newAccessPath(IIndexManager localIndexManager,
IPredicate<ISPO> predicate,
IKeyOrder<ISPO> keyOrder) |
Constructor and Description |
---|
SPOAccessPath(IRelation<ISPO> relation,
IIndexManager localIndexManager,
IPredicate<ISPO> predicate,
IKeyOrder<ISPO> keyOrder) |
SPORelation(AbstractTripleStore container,
IIndexManager indexManager,
String namespace,
Long timestamp,
Properties properties) |
SPORelation(IIndexManager indexManager,
String namespace,
Long timestamp,
Properties properties) |
Constructor and Description |
---|
AbstractLocalTripleStore(IIndexManager indexManager,
String namespace,
Long timestamp,
Properties properties) |
AbstractTripleStore(IIndexManager indexManager,
String namespace,
Long timestamp,
Properties properties)
Ctor specified by
DefaultResourceLocator . |
LocalTripleStore(IIndexManager indexManager,
String namespace,
Long timestamp,
Properties properties)
Ctor specified by
DefaultResourceLocator . |
ScaleOutTripleStore(IIndexManager indexManager,
String namespace,
Long timestamp,
Properties properties)
Ctor specified by
DefaultResourceLocator |
TempTripleStore(IIndexManager indexManager,
String namespace,
Long timestamp,
Properties properties)
Ctor specified by
DefaultResourceLocator . |
Modifier and Type | Method and Description |
---|---|
IIndexManager |
IApiTask.getIndexManager()
Return the
IIndexManager . |
IIndexManager |
AbstractApiTask.getIndexManager() |
Modifier and Type | Method and Description |
---|---|
void |
IApiTask.setIndexManager(IIndexManager indexManager)
Invoked to inform the task of the index manager before it is executed.
|
void |
AbstractApiTask.setIndexManager(IIndexManager indexManager) |
static <T> FutureTask<T> |
AbstractApiTask.submitApiTask(IIndexManager indexManager,
IApiTask<T> task)
Submit a task and return a
Future for that task. |
Constructor and Description |
---|
ApiTaskForIndexManager(IIndexManager indexManager,
IApiTask<T> delegate) |
Modifier and Type | Method and Description |
---|---|
protected static IIndexManager |
DumpLexicon.openIndexManager(String propertyFile)
Open the
IIndexManager identified by the property file. |
Modifier and Type | Field and Description |
---|---|
protected IIndexManager |
AbstractResource.indexManager |
Modifier and Type | Method and Description |
---|---|
IIndexManager |
RelationFusedView.getIndexManager()
Deprecated.
The
IIndexManager for the first relation in the view. |
IIndexManager |
AbstractResource.getIndexManager()
Return the object used to locate indices, relations, and relation
containers and to execute operations on those resources.
|
IIndexManager |
IRelation.getIndexManager()
The
IIndexManager for the IRelation . |
Modifier and Type | Method and Description |
---|---|
IAccessPath<E> |
RelationFusedView.getAccessPath(IIndexManager localIndexManagerIsIgnored,
IKeyOrder<E> keyOrderisIgnored,
IPredicate<E> predicate)
Deprecated.
|
IAccessPath<E> |
AbstractRelation.getAccessPath(IIndexManager localIndexManager,
IKeyOrder<E> keyOrder,
IPredicate<E> predicate) |
IAccessPath<E> |
IRelation.getAccessPath(IIndexManager localIndexManager,
IKeyOrder<E> keyOrder,
IPredicate<E> predicate)
Return the
IAccessPath for an IRelation using the
specified IIndexManager and IKeyOrder (core impl). |
static IIndex |
AbstractRelation.getIndex(IIndexManager indexManager,
String fqn,
long timestamp)
Return the named index using the timestamp for this view of the relation.
|
IAccessPath<E> |
AbstractRelation.newAccessPath(IIndexManager localIndexManager,
IPredicate<E> predicate,
IKeyOrder<E> keyOrder)
IAccessPath factory. |
Constructor and Description |
---|
AbstractRelation(IIndexManager indexManager,
String namespace,
Long timestamp,
Properties properties) |
AbstractRelation(ILocatableResource container,
IIndexManager indexManager,
String namespace,
Long timestamp,
Properties properties)
Alternative version used when a resource exists within some container.
|
AbstractResource(IIndexManager indexManager,
String namespace,
Long timestamp,
Properties properties) |
AbstractResource(ILocatableResource container,
IIndexManager indexManager,
String namespace,
Long timestamp,
Properties properties)
Alternative version used when a resource exists within some container.
|
Modifier and Type | Field and Description |
---|---|
protected IIndexManager |
AccessPath.indexManager
Access to the index, resource locator, executor service, etc.
|
Modifier and Type | Method and Description |
---|---|
IIndexManager |
AccessPath.getIndexManager() |
Constructor and Description |
---|
AccessPath(IRelation<R> relation,
IIndexManager localIndexManager,
IPredicate<R> predicate,
IKeyOrder<R> keyOrder) |
Modifier and Type | Field and Description |
---|---|
protected IIndexManager |
DefaultResourceLocator.indexManager |
Modifier and Type | Method and Description |
---|---|
void |
DefaultResourceLocator.add(IIndexManager indexManager)
Causes the
IIndexManager to be tested when attempting to resolve
a resource identifiers. |
protected Properties |
DefaultResourceLocator.locateResourceOn(IIndexManager indexManager,
String namespace,
long timestamp)
Return the
Properties that will be used to configure the
IRelation instance. |
protected T |
DefaultResourceLocator.newInstance(Class<? extends T> cls,
IIndexManager indexManager,
NT nt,
Properties properties)
Create a new view of the relation.
|
Modifier and Type | Method and Description |
---|---|
protected Properties |
DefaultResourceLocator.locateResource(String namespace,
long timestamp,
AtomicReference<IIndexManager> foundOn)
Note: Caller is synchronized for this namespace.
|
Constructor and Description |
---|
DefaultResourceLocator(IIndexManager indexManager,
IResourceLocator<T> delegate)
|
DefaultResourceLocator(IIndexManager indexManager,
IResourceLocator<T> delegate,
int cacheCapacity,
long cacheTimeout) |
Modifier and Type | Field and Description |
---|---|
protected IIndexManager |
AbstractJoinNexus.indexManager |
protected IIndexManager |
AbstractStepTask.indexManager |
Modifier and Type | Method and Description |
---|---|
IIndexManager |
AbstractJoinNexus.getIndexManager() |
IIndexManager |
IJoinNexus.getIndexManager()
Used to locate indices, relations and relation containers.
|
Modifier and Type | Method and Description |
---|---|
protected Map<String,IRelation> |
AbstractStepTask.getReadRelations(IIndexManager indexManager,
IStep step,
long timestamp)
Locate the distinct relation identifiers corresponding to the tail(s) of
each rule and resolve them to their relations.
|
protected Map<String,IRelation> |
AbstractStepTask.getWriteRelations(IIndexManager indexManager,
IStep step,
long timestamp)
Locate the distinct relation identifiers corresponding to the head of
each rule and resolve them to their relations.
|
IJoinNexus |
AbstractJoinNexusFactory.newInstance(IIndexManager indexManager) |
IJoinNexus |
IJoinNexusFactory.newInstance(IIndexManager indexManager)
Singleton factory for an
IJoinNexus instance for the given
indexManager. |
protected abstract IJoinNexus |
AbstractJoinNexusFactory.newJoinNexus(IIndexManager indexManager)
Factory for
IJoinNexus instances used by
AbstractJoinNexusFactory.newInstance(IIndexManager) as past of its singleton pattern. |
Constructor and Description |
---|
AbstractJoinNexus(IJoinNexusFactory joinNexusFactory,
IIndexManager indexManager) |
AbstractStepTask(ActionEnum action,
IJoinNexusFactory joinNexusFactory,
IStep step,
IIndexManager indexManager,
DataService dataService)
Base class handles submit either to the caller's
ExecutorService
or to the ConcurrencyManager IFF the task was submitted to a
DataService . |
MutationTask(ActionEnum action,
IJoinNexusFactory joinNexusFactory,
IStep step,
IIndexManager indexManager,
DataService dataService) |
ProgramTask(ActionEnum action,
IStep step,
IJoinNexusFactory joinNexusFactory,
IIndexManager indexManager)
Variant when the task will be executed directly by the caller.
|
QueryTask(IStep step,
IJoinNexusFactory joinNexusFactory,
IBlockingBuffer<ISolution[]> buffer,
IIndexManager indexManager,
DataService dataService) |
Modifier and Type | Class and Description |
---|---|
protected class |
AbstractResourceManagerTestCase.MockFederation
A minimal implementation of only those methods actually utilized by the
ResourceManager during the unit tests. |
class |
StoreManager.ManagedJournal
The
StoreManager.ManagedJournal provides the backing store used to absorb
writes and retain history for the scale-out architecture. |
Modifier and Type | Method and Description |
---|---|
protected static ProxyTestSuite |
TestAll.proxySuite(AbstractIndexManagerTestCase<? extends IIndexManager> delegate,
String name)
Create and populate a
ProxyTestSuite with the unit tests that we
will run against any of the IIndexManager implementations. |
Constructor and Description |
---|
FullTextIndex(IIndexManager indexManager,
String namespace,
Long timestamp,
Properties properties)
Ctor specified by
DefaultResourceLocator . |
Modifier and Type | Interface and Description |
---|---|
interface |
IBigdataFederation<T>
The client-facing interface to a bigdata federation.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractDistributedFederation<T>
Abstract base class for
IBigdataFederation implementations where the
services are distributed using RMI and are running, at least in principle,
across more than one host/JVM. |
class |
AbstractFederation<T>
Abstract base class for
IBigdataFederation implementations. |
class |
AbstractScaleOutFederation<T>
Abstract base class for federation implementations using the scale-out index
architecture (federations that support key-range partitioned indices).
|
class |
EmbeddedFederation<T>
An implementation that uses an embedded database rather than a distributed
database.
|
Modifier and Type | Method and Description |
---|---|
protected IIndex |
TestSparseRowStore.getIndex(IIndexManager store) |
Modifier and Type | Method and Description |
---|---|
protected static ProxyTestSuite |
TestAll.proxySuite(AbstractIndexManagerTestCase<? extends IIndexManager> delegate,
String name)
Create and populate a
ProxyTestSuite with the unit tests that we
will run against any of the IIndexManager implementations. |
Constructor and Description |
---|
GlobalRowStoreHelper(IIndexManager indexManager) |
Constructor and Description |
---|
Stream.StreamIndexMetadata(IIndexManager indexManager,
Properties properties,
String namespace,
UUID indexUUID)
Constructor used to configure a new named B+Tree.
|
Constructor and Description |
---|
DistinctFilter(IIndexManager indexManager)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected void |
SPARQLUpdateTestv2.tearDownBackend(IIndexManager backend) |
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.