|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object java.lang.Thread felix.dstruct.ConcurrentOperatorsBucket
public class ConcurrentOperatorsBucket
An object of ConcurrentOperatorsBucket contains
multiple statistical operators that can be executed in
parallel. ConcurrentOperatorsBucket is the basic unit
of the ExecutionPlan
.
Nested Class Summary |
---|
Nested classes/interfaces inherited from class java.lang.Thread |
---|
java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler |
Field Summary | |
---|---|
java.util.HashSet<java.lang.String> |
cleared
Auxiliary structure for clearing the old data table and merge the output of statistical operators in this bucket. |
java.util.HashSet<FelixPredicate> |
commonCandidates
Set of predicates that can potentially share with others (through dual decomposition). |
java.util.HashSet<FelixPredicate> |
dd_CommonOutput
Relations that are shared with other buckets through dual decomposition. |
java.util.HashMap<FelixPredicate,java.lang.String> |
dd_commonOutputPredicate_2_priorTableName
Map from relations in dd_CommonOutput
to tables containing their corresponding Langragian
Multipliers. |
java.util.HashMap<FelixPredicate,java.lang.String> |
dd_commonOutputPredicate_2_tableName
Map from relations in dd_CommonOutput
to tables containing their temporary output result in
each iteration. |
int |
id
ID of this bucket. |
java.util.HashSet<FelixPredicate> |
inputPredicates
Predicates used as inputs. |
java.util.HashSet<java.lang.String> |
inputPredicateScope
Predicates as input. |
int |
nStartingRule
Number of rules that only contains evidence relations. |
java.util.HashSet<FelixPredicate> |
outputPredicates
Predicates output by this bucket. |
int |
precedence
Precedence of this bucket. |
StatOperator.OPType |
type
Type of operators in this bucket. |
Fields inherited from class java.lang.Thread |
---|
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY |
Constructor Summary | |
---|---|
ConcurrentOperatorsBucket(boolean isMarginal)
The constructor. |
Method Summary | |
---|---|
void |
addCommonOutput(FelixPredicate _fp)
Adds predicate to dd_CommonOutput . |
void |
addMLNRelTable(java.lang.String tableName)
Register a table in subTuffyMLNRelTable . |
void |
addOperator(StatOperator sop)
Add an operator into this bucket. |
void |
cleanUp()
Merge the output of operators into a consistent DB table and dump them into files. |
void |
dumpMapAnswerForPredicate(tuffy.db.RDB db,
java.lang.String fout,
FelixPredicate p)
Deprecated. |
java.util.HashSet<StatOperator> |
getOperators()
Get all operators in this bucket. |
int |
getPrecedence()
Get the precedence of this bucket. |
boolean |
isMarginal()
Whether this bucket runs in marginal mode. |
void |
myJoin()
Deprecated. |
void |
prepareDB44DD()
Prepares database for dual decomposition -- 1) add new rules for Lagaragian Multipliers; 2) create tables for intermediate output and priors etc.. |
void |
pushPredicateScopes(java.util.HashSet<FelixPredicate> _predicates)
Deprecated. |
void |
run()
Run all operators in this bucket. |
void |
runNextOperatorInBucket()
Deprecated. |
void |
setNCore(int _nCore)
Set the degree of concurrency. |
java.lang.String |
toNoParString()
Returns string representation of bucket without partitioning info.. |
java.lang.String |
toString()
Returns string representation of bucket. |
Methods inherited from class java.lang.Thread |
---|
activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, yield |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
public java.util.HashSet<FelixPredicate> inputPredicates
public java.util.HashSet<java.lang.String> cleared
public java.util.HashSet<FelixPredicate> commonCandidates
public java.util.HashSet<FelixPredicate> outputPredicates
public java.util.HashSet<java.lang.String> inputPredicateScope
public int id
public StatOperator.OPType type
public int precedence
public int nStartingRule
public java.util.HashSet<FelixPredicate> dd_CommonOutput
public java.util.HashMap<FelixPredicate,java.lang.String> dd_commonOutputPredicate_2_tableName
dd_CommonOutput
to tables containing their temporary output result in
each iteration.
public java.util.HashMap<FelixPredicate,java.lang.String> dd_commonOutputPredicate_2_priorTableName
dd_CommonOutput
to tables containing their corresponding Langragian
Multipliers.
Constructor Detail |
---|
public ConcurrentOperatorsBucket(boolean isMarginal)
isMarginal
- Method Detail |
---|
public void addMLNRelTable(java.lang.String tableName)
subTuffyMLNRelTable
.
tableName
- public void pushPredicateScopes(java.util.HashSet<FelixPredicate> _predicates)
_predicates
- public boolean isMarginal()
public java.util.HashSet<StatOperator> getOperators()
public int getPrecedence()
public void addOperator(StatOperator sop)
sop
- public void setNCore(int _nCore)
_nCore
- public void addCommonOutput(FelixPredicate _fp)
dd_CommonOutput
.
_fp
- public void prepareDB44DD()
public void run()
run
in interface java.lang.Runnable
run
in class java.lang.Thread
public void cleanUp()
public void runNextOperatorInBucket()
public void myJoin()
public java.lang.String toString()
toString
in class java.lang.Thread
public java.lang.String toNoParString()
public void dumpMapAnswerForPredicate(tuffy.db.RDB db, java.lang.String fout, FelixPredicate p)
db
- fout
- p
-
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |