com.bigdata.relation.rule.eval
Class RunRuleAndFlushBufferTaskFactory

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

All Implemented Interfaces:

IRuleTaskFactory, Serializable

Deprecated. This is now handled by MutationTask.newMutationTasks(com.bigdata.relation.rule.IStep, IJoinNexus, java.util.Map)

public class RunRuleAndFlushBufferTaskFactory
extends Object
implements IRuleTaskFactory

Factory class is used for sequential IRule step execution. It wraps the selected IStepTask inside of a RunRuleAndFlushBufferTask to ensure that the IBuffer on which the IStepTask wrote its ISolutions gets IBuffer.flush()ed after the IStepTask is executed.

Version:

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

Author:

Bryan Thompson

See Also:

Serialized Form

Constructor Summary

RunRuleAndFlushBufferTaskFactory(IRuleTaskFactory delegate)
Deprecated.

Method Summary

IStepTask

newTask(IRule rule, IJoinNexus joinNexus, IBuffer<ISolution[]> buffer) Deprecated. The object will be used to evaluate the rule for the IRule.

Methods inherited from class java.lang.Object

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

Constructor Detail

RunRuleAndFlushBufferTaskFactory

public RunRuleAndFlushBufferTaskFactory(IRuleTaskFactory delegate)

Deprecated.

Method Detail

newTask

public IStepTask newTask(IRule rule,
                         IJoinNexus joinNexus,
                         IBuffer<ISolution[]> buffer)

Deprecated.

Description copied from interface: IRuleTaskFactory

The object will be used to evaluate the rule for the IRule.

Specified by:

newTask in interface IRuleTaskFactory

Parameters:

rule - The rule (MAY have been specialized since it was declared).

joinNexus - Encapsulates various important information required for join operations.

buffer - The buffer onto which chunks of computed ISolutions for the IRule must be written.

Returns:

null unless custom evaluation is desired.