Package | Description |
---|---|
com.bigdata.rdf.rules | |
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 | Method and Description |
---|---|
RuleStats |
AbstractRuleDistinctTermScan.DistinctTermScan.call() |
RuleStats |
AbstractRuleFastClosure_3_5_6_7_9.FastClosureRuleTask.call() |
Modifier and Type | Field and Description |
---|---|
List<RuleStats> |
RuleStats.detailStats
|
Modifier and Type | Method and Description |
---|---|
RuleStats |
MutationTask.call()
Run the task.
|
RuleStats |
RunRuleAndFlushBufferTask.call() |
RuleStats |
QueryTask.call()
Run the task (invoked once we are in the target execution context).
|
RuleStats |
IStepTask.call()
Evaluate the rule.
|
protected RuleStats |
ProgramTask.executeClosure(IProgram program)
Computes the closure of a set of
IRule s until the relation(s) on
which they are writing reach a "fixed point". |
protected RuleStats |
ProgramTask.executeMutation(IStep step)
Run a mutation
IStep . |
protected RuleStats |
ProgramTask.executeProgramWithEmbeddedClosure(IProgram program)
|
RuleStats |
IRuleStatisticsFactory.newInstance(IRuleState ruleState)
Used for the execution of a single
IRule . |
RuleStats |
IRuleStatisticsFactory.newInstance(IStep step)
Used for aggregations of more than one
IRule . |
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 RuleStats |
AbstractStepTask.runSequential(IJoinNexus joinNexus,
IStep program,
List<Callable<RuleStats>> tasks)
Run program steps in sequence.
|
protected RuleStats |
QueryTask.runTasks(IJoinNexus joinNexus,
List<Callable<RuleStats>> tasks)
Run the task(s) and wait for them to complete.
|
Modifier and Type | Method and Description |
---|---|
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.
|
Future<RuleStats> |
AbstractStepTask.submit()
Run this task.
|
Modifier and Type | Method and Description |
---|---|
void |
RuleStats.add(RuleStats o)
Aggregates statistics.
|
protected long |
MutationTask.getMutationCountFromBuffers(RuleStats totals,
Map<String,IBuffer<ISolution[]>> buffers)
This just reads off and aggregates the mutationCount from each buffer as
reported by
IBuffer.flush() . |
static void |
RuleLog.log(RuleStats stats)
Log rule execution statistics.
|
Modifier and Type | Method and Description |
---|---|
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 RuleStats |
AbstractStepTask.runSequential(IJoinNexus joinNexus,
IStep program,
List<Callable<RuleStats>> tasks)
Run program steps in sequence.
|
protected RuleStats |
QueryTask.runTasks(IJoinNexus joinNexus,
List<Callable<RuleStats>> tasks)
Run the task(s) and wait for them to complete.
|
Modifier and Type | Field and Description |
---|---|
protected RuleStats |
JoinMasterTask.ruleStats |
Modifier and Type | Method and Description |
---|---|
RuleStats |
JoinMasterTask.call()
Evaluate the rule.
|
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.