Package | Description |
---|---|
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 |
---|---|
static void |
RuleLog.log(IRule rule,
IRuleState ruleState,
JoinStats[] joinStats)
Log distributed join execution statistics using a CSV format.
|
Modifier and Type | Field and Description |
---|---|
protected JoinStats[] |
JoinMasterTask.joinStats
Statistics on
JoinTask behavior for each IPredicate in
the tail of the rule. |
Modifier and Type | Method and Description |
---|---|
void |
IJoinMaster.report(JoinStats joinStats)
Used to send join stats to the master.
|
void |
JoinMasterTask.report(JoinStats joinStats)
Aggregates the statistics for some join dimension.
|
static StringBuilder |
JoinStats.toString(IRule rule,
IRuleState ruleState,
JoinStats[] a)
Formats the array of
JoinStats into a CSV table view. |
Constructor and Description |
---|
UnsyncLocalOutputBuffer(JoinStats joinStats,
int capacity,
IBlockingBuffer<E[]> syncBuffer) |
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.