felix.executor
Class DDExecutor

java.lang.Object
  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 -