MutationTask.newMutationTasks(com.bigdata.relation.rule.IStep, IJoinNexus, java.util.Map)
public class RunRuleAndFlushBufferTaskFactory extends Object implements IRuleTaskFactory
IRule
step execution. It
wraps the selected IStepTask
inside of a
RunRuleAndFlushBufferTask
to ensure that the IBuffer
on
which the IStepTask
wrote its ISolution
s gets
IBuffer.flush()
ed after the IStepTask
is executed.Constructor and Description |
---|
RunRuleAndFlushBufferTaskFactory(IRuleTaskFactory delegate)
Deprecated.
|
public RunRuleAndFlushBufferTaskFactory(IRuleTaskFactory delegate)
public IStepTask newTask(IRule rule, IJoinNexus joinNexus, IBuffer<ISolution[]> buffer)
IRuleTaskFactory
IRule
.newTask
in interface IRuleTaskFactory
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 ISolution
s
for the IRule
must be written.null
unless custom evaluation is desired.Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.