com.bigdata.relation.rule.eval
Class RunRuleAndFlushBufferTask

java.lang.Object
  com.bigdata.relation.rule.eval.RunRuleAndFlushBufferTask

All Implemented Interfaces:

IStepTask, Serializable, Callable<RuleStats>

public class RunRuleAndFlushBufferTask
extends Object
implements IStepTask, Serializable

Helper class is used for sequential IRule step execution. It runs an IStepTask and then IBuffer.flush()s the IBuffer on which the IStepTask wrote its ISolutions.

Version:

$Id: RunRuleAndFlushBufferTask.java 2265 2009-10-26 12:51:06Z thompsonbry $

Author:

Bryan Thompson

See Also:

Serialized Form

Field Summary

protected static boolean	DEBUG
protected static org.apache.log4j.Logger	log

Constructor Summary

RunRuleAndFlushBufferTask(IStepTask stepTask, IBuffer<ISolution[]> buffer)

Method Summary

RuleStats

call() Evaluate the rule.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

log

protected static final org.apache.log4j.Logger log

DEBUG

protected static final boolean DEBUG

Constructor Detail

RunRuleAndFlushBufferTask

public RunRuleAndFlushBufferTask(IStepTask stepTask,
                                 IBuffer<ISolution[]> buffer)

Parameters:

stepTask - A task.

buffer - A thread-safe buffer containing chunks of ISolutions computed by that task.

Method Detail

call

public RuleStats call()
               throws Exception

Description copied from interface: IStepTask

Evaluate the rule.

Specified by:

call in interface IStepTask

Specified by:

call in interface Callable<RuleStats>

Throws:

Exception