Package | Description |
---|---|
com.bigdata.rdf.rules | |
com.bigdata.rdf.spo |
This package defines a statement model using long term identifiers rather than
RDF Value objects.
|
com.bigdata.relation.rule |
This package includes an abstraction layer for rules.
|
com.bigdata.relation.rule.eval |
This package supports rule evaluation.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractRuleDistinctTermScan
Base class for rules having a single predicate that is none bound in the tail
and a single variable in the head.
|
class |
AbstractRuleFastClosure_11_13
Rule for steps 11 and 13 of the "fast closure" method.
|
class |
AbstractRuleFastClosure_3_5_6_7_9
Rule used in steps 3, 5, 6, 7, and 9 of the fast forward closure program.
|
class |
AbstractRuleFastClosure_5_6_7_9 |
class |
MappedProgram
Program automatically maps the rules added across the combination of the
database (the relation named on the rule) and the focusStore.
|
class |
MatchRule
Rule supporting
AbstractTripleStore.match(Literal[], URI[], URI) . |
class |
RuleFastClosure11
Rule for step 11 of
InferenceEngine#fastForwardClosure() . |
class |
RuleFastClosure13
Rule for step 13 of
InferenceEngine#fastForwardClosure() . |
class |
RuleFastClosure3 |
class |
RuleFastClosure5 |
class |
RuleFastClosure6 |
class |
RuleFastClosure7 |
class |
RuleFastClosure9 |
class |
RuleOwlEquivalentClass
owl:equivalentClass
|
class |
RuleOwlEquivalentProperty
owl:equivalentProperty
|
class |
RuleOwlFunctionalProperty
owl:FunctionalProperty
|
class |
RuleOwlHasValue
owl:hasValue
|
class |
RuleOwlInverseFunctionalProperty
owl:InverseFunctionalProperty
|
class |
RuleOwlInverseOf1
owl:inverseOf1
|
class |
RuleOwlInverseOf2
owl:inverseOf2
|
class |
RuleOwlSameAs1
owl:sameAs1
|
class |
RuleOwlSameAs1b
owl:sameAs1b
|
class |
RuleOwlSameAs2
owl:sameAs2
|
class |
RuleOwlSameAs3
owl:sameAs3
|
class |
RuleOwlSymmetricProperty
owl:SymmetricProperty
|
class |
RuleOwlTransitiveProperty1
owl:TransitiveProperty1
|
class |
RuleOwlTransitiveProperty2
owl:TransitiveProperty2
|
class |
RuleRdf01
rdf1:
|
class |
RuleRdfs02
rdfs2:
|
class |
RuleRdfs03
rdfs3:
|
class |
RuleRdfs04a
rdfs4a:
|
class |
RuleRdfs04b
rdfs4b:
|
class |
RuleRdfs05
rdfs5: this variant uses a nested subquery and may be safely used during
truth maintenance.
|
class |
RuleRdfs06
rdfs6:
|
class |
RuleRdfs07
rdfs7:
|
class |
RuleRdfs08
rdfs8:
|
class |
RuleRdfs09
rdfs9:
|
class |
RuleRdfs10
rdfs10:
|
class |
RuleRdfs11
rdfs11: this variant uses a nested subquery and may be safely used during
truth maintenance.
|
class |
RuleRdfs12
rdfs12:
|
class |
RuleRdfs13
rdfs13:
|
Modifier and Type | Method and Description |
---|---|
void |
MappedProgram.addStep(IStep step)
Extended to add the N steps that map the given step across the
database and the focusStore.
|
Program |
TMUtility.mapForTruthMaintenance(IStep step,
String focusStore) |
Modifier and Type | Class and Description |
---|---|
protected class |
TestSPORelation.TestRuleRdfs9
this is rdfs9:
|
Modifier and Type | Interface and Description |
---|---|
interface |
IProgram
A program consists of a set of rules and/or programs.
|
interface |
IRule<E>
Conjunctive query of N
IPredicate s with optional IConstraint s. |
Modifier and Type | Class and Description |
---|---|
protected static class |
AbstractRuleTestCase.MyRule |
protected static class |
AbstractRuleTestCase.TestRuleRdfs04a
rdfs4a:
|
protected static class |
AbstractRuleTestCase.TestRuleRdfs9
this is rdfs9:
|
class |
Program
Mutable program may be used to create a variety of rule executions.
|
class |
Rule<E>
Default impl.
|
Modifier and Type | Method and Description |
---|---|
IStep[] |
Program.toArray() |
IStep[] |
IProgram.toArray()
An array containing the steps in the program (non-recursive).
|
Modifier and Type | Method and Description |
---|---|
Iterator<IStep> |
Program.steps() |
Iterator<IStep> |
IProgram.steps()
The sequence of sub-program
IStep s. |
Modifier and Type | Method and Description |
---|---|
void |
Program.addStep(IStep step)
Add another step in the program.
|
Modifier and Type | Method and Description |
---|---|
void |
Program.addSteps(Iterator<? extends IStep> steps)
Adds the steps to the program.
|
Modifier and Type | Field and Description |
---|---|
IStep |
RuleStats.rule
The
IStep that was executed. |
protected IStep |
AbstractStepTask.step |
Modifier and Type | Method and Description |
---|---|
protected RuleStats |
ProgramTask.executeMutation(IStep step)
Run a mutation
IStep . |
protected IAsynchronousIterator<ISolution[]> |
ProgramTask.executeQuery(IStep step)
Execute the
IStep as a query. |
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 Set<String> |
AbstractStepTask.getWriteRelationNames(IStep step)
The set of distinct relations identified by the head of each rule in the
program.
|
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.
|
boolean |
ProgramUtility.isClosureProgram(IStep step)
true iff the program contains an embedded closure
operation. |
protected boolean |
AbstractJoinNexus.isEmptyProgram(IStep step)
Return true iff the step is an empty
IProgram . |
RuleStats |
IRuleStatisticsFactory.newInstance(IStep step)
Used for aggregations of more than one
IRule . |
protected List<Callable<RuleStats>> |
MutationTask.newMutationTasks(IStep step,
IJoinNexus joinNexus,
Map<String,IBuffer<ISolution[]>> buffers)
Builds a set of tasks for the program.
|
protected List<Callable<RuleStats>> |
QueryTask.newQueryTasks(IStep step,
IJoinNexus joinNexus,
IBlockingBuffer<ISolution[]> buffer)
Builds a set of tasks for the program.
|
protected Object |
AbstractJoinNexus.runDistributedProgram(IBigdataFederation<?> fed,
ActionEnum action,
IStep step)
Runs a distributed
IProgram (key-range partitioned indices, RMI,
and multi-machine). |
protected Object |
AbstractJoinNexus.runLocalProgram(ActionEnum action,
IStep step)
This variant handles both local indices on a
TemporaryStore or
Journal WITHOUT concurrency controls (fast). |
long |
AbstractJoinNexus.runMutation(IStep step) |
long |
IJoinNexus.runMutation(IStep step)
Run as mutation operation (it will write any solutions onto the relations
named in the head of the various
IRule s). |
protected RuleStats |
AbstractStepTask.runOne(IJoinNexus joinNexus,
IStep program,
Callable<RuleStats> task)
Run a single step (sequence of one).
|
protected RuleStats |
AbstractStepTask.runParallel(IJoinNexus joinNexus,
IStep program,
List<Callable<RuleStats>> tasks)
Run program steps in parallel.
|
protected Object |
AbstractJoinNexus.runProgram(ActionEnum action,
IStep step)
Core impl.
|
IChunkedOrderedIterator<ISolution> |
AbstractJoinNexus.runQuery(IStep step) |
IChunkedOrderedIterator<ISolution> |
IJoinNexus.runQuery(IStep step)
Run as a query.
|
protected RuleStats |
AbstractStepTask.runSequential(IJoinNexus joinNexus,
IStep program,
List<Callable<RuleStats>> tasks)
Run program steps in sequence.
|
Constructor and Description |
---|
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 . |
EmptyProgramTask(ActionEnum action,
IStep step) |
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) |
RuleStats(IStep step)
Initializes statistics for an
IStep . |
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.