public class SubPipeline extends Object
Node
s of this sub pipline must already be connected to each other via
Node.appendSuccessor(Node)
and Node.prependPredecessor(Node)
, but the first and
last Node—which might be both the one and only Node
—must be announced via the
methods startWith(StreamBundle, Node)
and endWith(Node, StreamBundle)
.JobListener.subPipelineCreated(com.levigo.jadice.server.Job, Node, java.util.Set)
Modifier and Type | Method and Description |
---|---|
SubPipeline |
endWith(Node lastChild,
StreamBundle output)
The sub pipeline shall end at the given
Node and shall provide its processed data through the
given StreamBundle . |
static SubPipeline |
forParent(NodeWorker<?> parent)
Start the creation of a sub pipeline
|
SubPipeline |
inheritLimits()
|
void |
start()
Creates and starts the sub pipeline.
|
SubPipeline |
startWith(StreamBundle input,
Node firstChild)
The sub pipeline shall start at the given
Node and will be feed with data through the
given StreamBundle . |
public static SubPipeline forParent(NodeWorker<?> parent)
parent
- the sub pipeline will be created on behalf of this Node
public SubPipeline startWith(StreamBundle input, Node firstChild)
Node
and will be feed with data through the
given StreamBundle
. Calling this method if mandatory.input
- The StreamBundle
that feeds the sub pipeline with data which already must be complete.firstChild
- The first Node
of the sub pipelineSubPipeline
builder itself (fluent style API)public SubPipeline endWith(Node lastChild, StreamBundle output)
Node
and shall provide its processed data through the
given StreamBundle
. Calling this method if mandatory.lastChild
- the last Node
of the sub pipelineoutput
- The resulting Stream
s of the sub pipeline shall be provided hereSubPipeline
builder itself (fluent style API)public SubPipeline inheritLimits()
Node
s of the sub pipeline shall inherit the Limit
s of
the parent Node
. Calling this method if optional.SubPipeline
builder itself (fluent style API)public void start() throws ConfigurationException
ConfigurationException
- if preconditions were not met.Copyright © 2017 levigo holding gmbh. All rights reserved.