Package | Description |
---|---|
com.bigdata.bop.ap | |
com.bigdata.rdf.rules | |
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.relation.rule.eval |
This package supports rule evaluation.
|
com.bigdata.relation.rule.eval.pipeline |
This package implements a pipeline join.
|
Modifier and Type | Class and Description |
---|---|
class |
MockJoinNexusFactory
Mock object.
|
Modifier and Type | Class and Description |
---|---|
class |
RDFJoinNexusFactory
Factory for
RDFJoinNexus objects. |
Modifier and Type | Method and Description |
---|---|
IJoinNexusFactory |
AbstractTripleStore.newJoinNexusFactory(RuleContextEnum ruleContext,
ActionEnum action,
int solutionFlags,
IElementFilter filter) |
IJoinNexusFactory |
AbstractTripleStore.newJoinNexusFactory(RuleContextEnum ruleContext,
ActionEnum action,
int solutionFlags,
IElementFilter filter,
boolean justify,
boolean backchain,
IEvaluationPlanFactory planFactory) |
IJoinNexusFactory |
AbstractTripleStore.newJoinNexusFactory(RuleContextEnum ruleContext,
ActionEnum action,
int solutionFlags,
IElementFilter filter,
boolean justify,
boolean backchain,
IEvaluationPlanFactory planFactory,
Properties overrides) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractJoinNexusFactory
Base implementation for
IJoinNexusFactory . |
Modifier and Type | Field and Description |
---|---|
protected IJoinNexusFactory |
AbstractStepTask.joinNexusFactory |
Modifier and Type | Method and Description |
---|---|
IJoinNexusFactory |
AbstractJoinNexus.getJoinNexusFactory() |
IJoinNexusFactory |
IJoinNexus.getJoinNexusFactory()
The factory object is used to materialize appropriate
IJoinNexus
instances when the rule execution crosses an RMI boundary. |
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)
Variant when the task will be submitted using
IDataService.submit(Callable) (efficient since all indices will
be local, but the indices must not be partitioned and must all exist on
the target 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 | Field and Description |
---|---|
protected IJoinNexusFactory |
JoinMasterTask.joinNexusFactory |
Constructor and Description |
---|
JoinTaskFactoryTask(String scaleOutIndexName,
IRule rule,
IJoinNexusFactory joinNexusFactory,
int[] order,
int orderIndex,
int partitionId,
IJoinMaster masterProxy,
UUID masterUUID,
IAsynchronousIterator<IBindingSet[]> sourceItrProxy,
IKeyOrder[] keyOrders,
IVariable[][] requiredVars) |
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.