|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object felix.dstruct.OperatorBucketGraph
public class OperatorBucketGraph
The class of an OperatorBucketGraph. Each operator graph contains 1) a set of
ConcurrentOperatorsBucket
; and 2) Dependencies between different buckets.
Current assumption is DAG (although there are no data-structure-level constraints
for DAG, some algorithms may become trivial when dealing with cycles).
An OperatorBucketGraph is a complete description of the logic plan.
Field Summary | |
---|---|
java.util.HashMap<ConcurrentOperatorsBucket,java.util.HashSet<ConcurrentOperatorsBucket>> |
downStreams
Map from the bucket to its downstream buckets. |
java.util.HashMap<ConcurrentOperatorsBucket,java.util.HashSet<ConcurrentOperatorsBucket>> |
upStreams
Map from the bucket to its upstream buckets. |
Constructor Summary | |
---|---|
OperatorBucketGraph()
|
Method Summary | |
---|---|
void |
addOperator(ConcurrentOperatorsBucket sop)
Add a new bucket to this OperatorBucketGraph. |
java.util.HashSet<ConcurrentOperatorsBucket> |
getDownStreamOperator(ConcurrentOperatorsBucket oup)
Gets all downstream buckets of the given bucket. |
ConcurrentOperatorsBucket |
getOneRandomOperator()
Randomly pick one bucket in this OperatorBucketGraph. |
java.util.HashSet<ConcurrentOperatorsBucket> |
getOperators()
Return the set of buckets in this OperatorBucketGraph. |
java.util.HashSet<ConcurrentOperatorsBucket> |
getUpStreamOperator(ConcurrentOperatorsBucket sop)
Gets all upstream buckets of the given bucket. |
void |
parseDependency()
Parse the dependency between buckets. |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public java.util.HashMap<ConcurrentOperatorsBucket,java.util.HashSet<ConcurrentOperatorsBucket>> upStreams
public java.util.HashMap<ConcurrentOperatorsBucket,java.util.HashSet<ConcurrentOperatorsBucket>> downStreams
Constructor Detail |
---|
public OperatorBucketGraph()
Method Detail |
---|
public void addOperator(ConcurrentOperatorsBucket sop)
sop
- statistical operator.public void parseDependency()
public java.util.HashSet<ConcurrentOperatorsBucket> getOperators()
public ConcurrentOperatorsBucket getOneRandomOperator()
public java.util.HashSet<ConcurrentOperatorsBucket> getUpStreamOperator(ConcurrentOperatorsBucket sop)
public java.util.HashSet<ConcurrentOperatorsBucket> getDownStreamOperator(ConcurrentOperatorsBucket oup)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |