felix.executor
Class DDExecutor

java.lang.Object
  extended by felix.executor.DDExecutor

public class DDExecutor
extends java.lang.Object

Class for executing a given physical ExecutionPlan using dual decomposition.

Author:
Ce Zhang

Field Summary
 DMOOptimizer dmoo
          The DMOOptimizer used by this Executor.
 
Constructor Summary
DDExecutor(ExecutionPlan _ep, FelixQuery _fq, FelixCommandOptions _options)
          The constructor.
 
Method Summary
 void dumpMapAnswerForPredicate(tuffy.db.RDB db, FelixPredicate p, java.io.BufferedWriter bufferedWriter)
          Output the results of this bucket.
 void run()
          Execute this plan.
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

dmoo

public DMOOptimizer dmoo
The DMOOptimizer used by this Executor.

Constructor Detail

DDExecutor

public DDExecutor(ExecutionPlan _ep,
                  FelixQuery _fq,
                  FelixCommandOptions _options)
The constructor.

Parameters:
_ep -
Method Detail

run

public void run()
Execute this plan. If Felix runs in explain mode, just prints out the physical plan.

TODO: Find a better way to the explain mode (e.g., a graph).


dumpMapAnswerForPredicate

public void dumpMapAnswerForPredicate(tuffy.db.RDB db,
                                      FelixPredicate p,
                                      java.io.BufferedWriter bufferedWriter)
Output the results of this bucket.

Parameters:
db -
fout -
p -