|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Packages that use RuleStats | |
|---|---|
| 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. |
| Uses of RuleStats in com.bigdata.rdf.rules |
|---|
| Methods in com.bigdata.rdf.rules that return RuleStats | |
|---|---|
RuleStats |
AbstractRuleDistinctTermScan.DistinctTermScan.call()
|
RuleStats |
AbstractRuleFastClosure_3_5_6_7_9.FastClosureRuleTask.call()
|
| Uses of RuleStats in com.bigdata.relation.rule.eval |
|---|
| Fields in com.bigdata.relation.rule.eval with type parameters of type RuleStats | |
|---|---|
List<RuleStats> |
RuleStats.detailStats
When execution RuleStates are being aggregated, this will contain
the individual RuleStats for each execution RuleState. |
| Methods in com.bigdata.relation.rule.eval that return RuleStats | |
|---|---|
RuleStats |
IStepTask.call()
Evaluate the rule. |
RuleStats |
RunRuleAndFlushBufferTask.call()
|
RuleStats |
QueryTask.call()
Run the task (invoked once we are in the target execution context). |
RuleStats |
MutationTask.call()
Run the task. |
protected RuleStats |
ProgramTask.executeClosure(IProgram program)
Computes the closure of a set of IRules 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)
Execute an IProgram containing one or more sub-IProgram
that are closure operations. |
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. |
| Methods in com.bigdata.relation.rule.eval that return types with arguments of type RuleStats | |
|---|---|
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. |
| Methods in com.bigdata.relation.rule.eval with parameters of type RuleStats | |
|---|---|
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. |
| Method parameters in com.bigdata.relation.rule.eval with type arguments of type RuleStats | |
|---|---|
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. |
| Uses of RuleStats in com.bigdata.relation.rule.eval.pipeline |
|---|
| Fields in com.bigdata.relation.rule.eval.pipeline declared as RuleStats | |
|---|---|
protected RuleStats |
JoinMasterTask.ruleStats
|
| Methods in com.bigdata.relation.rule.eval.pipeline that return RuleStats | |
|---|---|
RuleStats |
JoinMasterTask.call()
Evaluate the rule. |
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||