Package org.processmining.specpp.base.impls

Class PostProcessingPipeline<R extends Result,F extends Result>

java.lang.Object

org.processmining.specpp.base.impls.PostProcessingPipeline<R,F>

All Implemented Interfaces:

java.util.function.Function<R,F>, PostProcessor<R,F>

public class PostProcessingPipeline<R extends Result,F extends Result>
extends java.lang.Object
implements PostProcessor<R,F>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PostProcessingPipeline.IncompatiblePostProcessorException

Constructor Summary

Constructors

Constructor	Description
PostProcessingPipeline(PostProcessor<R,?> head, java.util.List<PostProcessor<?,?>> line, PostProcessor<?,F> tail)
PostProcessingPipeline(PostProcessor<R,F> head)

Method Summary

Modifier and Type	Method	Description
<K extends Result> PostProcessingPipeline<R,K>	add(PostProcessor<? super F,K> next)
java.lang.Class<R>	getInputClass()
java.lang.Class<F>	getOutputClass()
int	getPipelineLength()
F	postProcess(R result)
F	postProcess(R result, java.util.function.Consumer<Result> callback)
F	postProcessInterruptibly(R result)
protected static <I extends Result,O extends Result> O	tryme(PostProcessor<I,O> pp, I r)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Function

andThen, compose

Methods inherited from interface org.processmining.specpp.base.PostProcessor

apply, getLabel

Constructor Detail

PostProcessingPipeline

public PostProcessingPipeline(PostProcessor<R,F> head)

PostProcessingPipeline

public PostProcessingPipeline(PostProcessor<R,?> head,
                              java.util.List<PostProcessor<?,?>> line,
                              PostProcessor<?,F> tail)

Method Detail

add

public <K extends Result> PostProcessingPipeline<R,K> add(PostProcessor<? super F,K> next)

postProcess

public F postProcess(R result)

Specified by:

postProcess in interface PostProcessor<R extends Result,F extends Result>

postProcess

public F postProcess(R result,
                     java.util.function.Consumer<Result> callback)

postProcessInterruptibly

public F postProcessInterruptibly(R result)
                           throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

tryme

protected static <I extends Result,O extends Result> O tryme(PostProcessor<I,O> pp,
                                                                   I r)

getPipelineLength

public int getPipelineLength()

getInputClass

public java.lang.Class<R> getInputClass()

Specified by:

getInputClass in interface PostProcessor<R extends Result,F extends Result>

getOutputClass

public java.lang.Class<F> getOutputClass()

Specified by:

getOutputClass in interface PostProcessor<R extends Result,F extends Result>