Class SelfEmptyingSummarizingBufferPipe<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>
-
- org.processmining.specpp.supervision.piping.SelfEmptyingSummarizingBufferPipe<I,O>
-
- All Implemented Interfaces:
java.util.function.Consumer<I>,AsyncAwareObservable<O>,Buffering,Observable<O>,ObservationPipe<I,O>,Observer<I>,Triggerable
public class SelfEmptyingSummarizingBufferPipe<I extends Observation,O extends Observation> extends SummarizingBufferPipe<I,O>
-
-
Field Summary
-
Fields inherited from class org.processmining.specpp.supervision.piping.AbstractBufferingPipe
buffer, hasThreadsafeBuffer
-
-
Constructor Summary
Constructors Constructor Description SelfEmptyingSummarizingBufferPipe(ObservationSummarizer<? super I,? extends O> summarizer, int capacityThreshold)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected voidbuffer(I observation)-
Methods inherited from class org.processmining.specpp.supervision.piping.SummarizingBufferPipe
collect
-
Methods inherited from class org.processmining.specpp.supervision.piping.AbstractBufferingPipe
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.Observable
addObserver, beObservedBy, clearObservers, getObservers, publish, removeObserver
-
-
-
-
Constructor Detail
-
SelfEmptyingSummarizingBufferPipe
public SelfEmptyingSummarizingBufferPipe(ObservationSummarizer<? super I,? extends O> summarizer, int capacityThreshold)
-
-
Method Detail
-
buffer
protected void buffer(I observation)
- Overrides:
bufferin classAbstractBufferingPipe<I extends Observation,O extends Observation>
-
-