Package org.processmining.specpp.supervision.piping

Class SummarizingBufferPipe<I extends Observation,O extends Observation>

java.lang.Object

org.processmining.specpp.supervision.piping.AbstractObservable<O>

org.processmining.specpp.supervision.piping.AbstractAsyncAwareObservable<O>

org.processmining.specpp.supervision.piping.AbstractBufferingPipe<I,O>

org.processmining.specpp.supervision.piping.SummarizingBufferPipe<I,O>

All Implemented Interfaces:

java.util.function.Consumer<I>, AsyncAwareObservable<O>, Buffering, Observable<O>, ObservationPipe<I,O>, Observer<I>, Triggerable

Direct Known Subclasses:

AsyncSummarizingBufferPipe, SelfEmptyingSummarizingBufferPipe

public class SummarizingBufferPipe<I extends Observation,O extends Observation>
extends AbstractBufferingPipe<I,O>

Field Summary

Fields inherited from class org.processmining.specpp.supervision.piping.AbstractBufferingPipe

buffer, hasThreadsafeBuffer

Constructor Summary

Constructors

Modifier	Constructor	Description
	SummarizingBufferPipe(ObservationSummarizer<? super I,? extends O> summarizer)
protected	SummarizingBufferPipe(ObservationSummarizer<? super I,? extends O> summarizer, boolean useConcurrentBuffer)

Method Summary

Modifier and Type	Method	Description
protected O	collect(Observations<I> bufferedObservations)

Methods inherited from class org.processmining.specpp.supervision.piping.AbstractBufferingPipe

buffer, drainBuffer, flushBuffer, hasThreadsafeBuffer, isBufferNonEmpty, observe

Methods inherited from class org.processmining.specpp.supervision.piping.AbstractAsyncAwareObservable

addObserver, getAsyncObservers, getNonAsyncObservers

Methods inherited from class org.processmining.specpp.supervision.piping.AbstractObservable

clearObservers, getObservers, publish, removeObserver

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.processmining.specpp.supervision.piping.AsyncAwareObservable

publishFutureToAsyncObservers, publishFutureToNonAsyncObservers

Methods inherited from interface org.processmining.specpp.supervision.piping.Buffering

trigger

Methods inherited from interface java.util.function.Consumer

andThen

Methods inherited from interface org.processmining.specpp.supervision.piping.Observable

addObserver, beObservedBy, clearObservers, getObservers, publish, removeObserver

Methods inherited from interface org.processmining.specpp.supervision.piping.Observer

accept

Constructor Detail

SummarizingBufferPipe

public SummarizingBufferPipe(ObservationSummarizer<? super I,? extends O> summarizer)

SummarizingBufferPipe

protected SummarizingBufferPipe(ObservationSummarizer<? super I,? extends O> summarizer,
                                boolean useConcurrentBuffer)

Method Detail

collect

protected O collect(Observations<I> bufferedObservations)

Specified by:

collect in class AbstractBufferingPipe<I extends Observation,O extends Observation>