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$

Author:

Bryan Thompson

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected static boolean	DEBUG
protected static org.apache.log4j.Logger	log

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
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