Uses of Interface
com.bigdata.relation.rule.IStep

Packages that use IStep

com.bigdata.rdf.rules
com.bigdata.relation.rule	This package includes an abstraction layer for rules.
com.bigdata.relation.rule.eval	This package supports rule evaluation.

Uses of IStep in com.bigdata.rdf.rules

Classes in com.bigdata.rdf.rules that implement IStep

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	RuleOwlHasValue owl:hasValue
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:
class	SampleRule If A is similar to B and both are of the same real type (not rdfs:Resource), then attach B's datatype properties (literals) to A as well.

Methods in com.bigdata.rdf.rules with parameters of type IStep

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)

Uses of IStep in com.bigdata.relation.rule

Subinterfaces of IStep in com.bigdata.relation.rule

interface	IProgram A program consists of a set of rules and/or programs.
interface	IRule<E> Conjunctive query of N IPredicates with optional IConstraints.

Classes in com.bigdata.relation.rule that implement IStep

class	Program Mutable program may be used to create a variety of rule executions.
class	Rule<E> Default impl.

Methods in com.bigdata.relation.rule that return IStep

IStep[]	IProgram.toArray() An array containing the steps in the program (non-recursive).
IStep[]	Program.toArray()

Methods in com.bigdata.relation.rule that return types with arguments of type IStep

Iterator<IStep>	IProgram.steps() The sequence of sub-program ISteps.
Iterator<IStep>	Program.steps()

Methods in com.bigdata.relation.rule with parameters of type IStep

void	Program.addStep(IStep step) Add another step in the program.

Method parameters in com.bigdata.relation.rule with type arguments of type IStep

void	Program.addSteps(Iterator<? extends IStep> steps) Adds the steps to the program.

Uses of IStep in com.bigdata.relation.rule.eval

Fields in com.bigdata.relation.rule.eval declared as IStep

IStep	RuleStats.rule The IStep that was executed.
protected IStep	AbstractStepTask.step

Methods in com.bigdata.relation.rule.eval with parameters of type IStep

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	IJoinNexus.runMutation(IStep step) Run as mutation operation (it will write any solutions onto the relations named in the head of the various IRules).
long	AbstractJoinNexus.runMutation(IStep step)
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>	IJoinNexus.runQuery(IStep step) Run as a query.
IChunkedOrderedIterator<ISolution>	AbstractJoinNexus.runQuery(IStep step)
protected RuleStats	AbstractStepTask.runSequential(IJoinNexus joinNexus, IStep program, List<Callable<RuleStats>> tasks) Run program steps in sequence.

Constructors in com.bigdata.relation.rule.eval with parameters of type IStep

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.