Field Detail

• private boolean complete

• private final PGroup group

• private DataflowReadChannel output

Constructor Detail

• public Pipeline(DataflowReadChannel output)

• public Pipeline(Pool pool, DataflowReadChannel output)

• public Pipeline(PGroup group, DataflowReadChannel output)

Method Detail

• public void binaryChoice(DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)

  Directs the output to one of the two output channels depending on the boolean result of the provided closure.

  Parameters:

  trueBranch - The channel to send data to if the closure returns true

  falseBranch - The channel to send data to if the closure returns true

  code - A closure directing data to either the true or the false output branch

• public void binaryChoice(java.util.Map<java.lang.String, java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)

  Directs the output to one of the two output channels depending on the boolean result of the provided closure.

  Parameters:

  params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)

  trueBranch - The channel to send data to if the closure returns true

  falseBranch - The channel to send data to if the closure returns true

  code - A closure directing data to either the true or the false output branch

• public Pipeline chainWith(groovy.lang.Closure<V> closure)

  Creates and attaches a new operator

  Returns:

  This Pipeline instance

  Parameters:

  closure - The function to invoke on all incoming values as part of the new operator's body

  - The type of values returned from the supplied closure

• public Pipeline chainWith(java.util.Map<java.lang.String, java.lang.Object> params, groovy.lang.Closure<V> closure)

  Creates and attaches a new operator

  Returns:

  This Pipeline instance

  Parameters:

  params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)

  closure - The function to invoke on all incoming values as part of the new operator's body

  - The type of values returned from the supplied closure

• private void checkState()

• public void choice(java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)

  Directs the output to one of the output channels depending on the int result of the provided closure.

  Parameters:

  outputs - The channels to send data to.

  code - A closure returning an index of the output channel to direct the data to

• public void choice(java.util.Map<java.lang.String, java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)

  Directs the output to one of the output channels depending on the int result of the provided closure.

  Parameters:

  params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)

  outputs - The channels to send data to.

  code - A closure returning an index of the output channel to direct the data to

• public Pipeline filter(groovy.lang.Closure<java.lang.Boolean> closure)

  Creates and attaches a new operator that will filter data using the provided closure

  Returns:

  This Pipeline instance

  Parameters:

  closure - The filter function to invoke on all incoming values to decide whether to pass the value on or not

• public Pipeline filter(java.util.Map<java.lang.String, java.lang.Object> params, groovy.lang.Closure<java.lang.Boolean> closure)

  Creates and attaches a new operator that will filter data using the provided closure

  Returns:

  This Pipeline instance

  Parameters:

  params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)

  closure - The filter function to invoke on all incoming values to decide whether to pass the value on or not

• public PGroup getGroup()

• public DataflowReadChannel getOutput()

• public void into(DataflowWriteChannel<V> target)

  Makes the output of the pipeline to be an input for the specified channel

  Parameters:

  target - The channel to copy data into

  - The type of values passed between the channels

• public void into(java.util.Map<java.lang.String, java.lang.Object> params, DataflowWriteChannel<V> target)

  Makes the output of the pipeline to be an input for the specified channel

  Parameters:

  params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)

  target - The channel to copy data into

  - The type of values passed between the channels

• public boolean isComplete()

• Pipeline merge(DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure closure)

  Merges channels together as inputs for a single dataflow operator.

  Returns:

  A channel of the same type as this channel, which the new operator will output into.

  Parameters:

  other - The channel to merge with

  closure - The function to invoke on all incoming values as part of the new operator's body. The number of arguments to the closure must match the number of input channels.

• Pipeline merge(java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure closure)

  Merges channels together as inputs for a single dataflow operator.

  Returns:

  A channel of the same type as this channel, which the new operator will output into.

  Parameters:

  others - The channels to merge with

  closure - The function to invoke on all incoming values as part of the new operator's body. The number of arguments to the closure must match the number of input channels.

• Pipeline merge(java.util.Map<java.lang.String, java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure closure)

  Merges channels together as inputs for a single dataflow operator.

  Returns:

  A channel of the same type as this channel, which the new operator will output into.

  Parameters:

  params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)

  other - The channel to merge with

  closure - The function to invoke on all incoming values as part of the new operator's body. The number of arguments to the closure must match the number of input channels.

• Pipeline merge(java.util.Map<java.lang.String, java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure closure)

  Merges channels together as inputs for a single dataflow operator.

  Returns:

  A channel of the same type as this channel, which the new operator will output into.

  Parameters:

  params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)

  others - The channels to merge with

  closure - The function to invoke on all incoming values as part of the new operator's body. The number of arguments to the closure must match the number of input channels.

• public Pipeline or(groovy.lang.Closure<V> closure)

  Creates and attaches a new operator

  Returns:

  This Pipeline instance

  Parameters:

  closure - The function to invoke on all incoming values as part of the new operator's body

  - The type of values returned from the supplied closure

• public void or(DataflowWriteChannel<V> target)

  Makes the output of the pipeline to be an input for the specified channel

  Parameters:

  target - The channel to copy data into

  - The type of values passed between the channels

• public void separate(java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)

  Allows the closure to output different values to different output channels.

  Parameters:

  outputs - The channels to send data to.

  code - A closure returning a list of values to pass to the output channels. Values are output to the output channels with identical index.

• public void separate(java.util.Map<java.lang.String, java.lang.Object> params, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)

  Allows the closure to output different values to different output channels.

  Parameters:

  params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)

  outputs - The channels to send data to.

  code - A closure returning a list of values to pass to the output channels. Values are output to the output channels with identical index.

• public void split(DataflowWriteChannel<V> target1, DataflowWriteChannel<V> target2)

  Splits the output of the pipeline to be an input for the specified channels

  Parameters:

  target1 - The first channel to copy data into

  target2 - The second channel to copy data into

  - The type of values passed between the channels

• public void split(java.util.List<DataflowWriteChannel<V>> targets)

  Makes the output of the pipeline to be an input for the specified channels

  Parameters:

  targets - The channels to copy data into

  - The type of values passed between the channels

• public void split(java.util.Map<java.lang.String, java.lang.Object> params, DataflowWriteChannel<V> target1, DataflowWriteChannel<V> target2)

  Splits the output of the pipeline to be an input for the specified channels

  Parameters:

  params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)

  target1 - The first channel to copy data into

  target2 - The second channel to copy data into

  - The type of values passed between the channels

• public void split(java.util.Map<java.lang.String, java.lang.Object> params, java.util.List<DataflowWriteChannel<V>> targets)

  Makes the output of the pipeline to be an input for the specified channels

  Parameters:

  params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)

  targets - The channels to copy data into

  - The type of values passed between the channels

• public Pipeline tap(DataflowWriteChannel<V> target)

  Taps into the pipeline at the current position, sending all data that pass through the pipeline also to the channel specified.

  Returns:

  This Pipeline instance

  Parameters:

  target - The channel to tap data into

  - The type of values passed between the channels

• public Pipeline tap(java.util.Map<java.lang.String, java.lang.Object> params, DataflowWriteChannel<V> target)

  Taps into the pipeline at the current position, sending all data that pass through the pipeline also to the channel specified.

  Returns:

  This Pipeline instance

  Parameters:

  params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)

  target - The channel to tap data into

  - The type of values passed between the channels