Package org.processmining.specpp.supervision

Class CSVWriter<O extends Observation>

java.lang.Object

org.processmining.specpp.supervision.CSVWriter<O>

All Implemented Interfaces:

java.util.function.Consumer<O>, AsyncObserver<O>, Buffering, Observer<O>, Stoppable, Triggerable

public class CSVWriter<O extends Observation>
extends java.lang.Object
implements AsyncObserver<O>, Buffering, Stoppable

Constructor Summary

Constructors

Constructor	Description
CSVWriter(java.lang.String filePath, java.lang.String[] columnLabels, java.util.function.Function<O,java.lang.String[]> rowMapper)

Method Summary

Modifier and Type	Method	Description
protected void	finalize()
void	flushBuffer()
boolean	isBufferNonEmpty()
void	observe(O observation)
void	observeAsync(java.util.concurrent.CompletableFuture<O> futureObservation)
void	stop()

Methods inherited from class java.lang.Object

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

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.Observer

accept

Constructor Detail

CSVWriter

public CSVWriter(java.lang.String filePath,
                 java.lang.String[] columnLabels,
                 java.util.function.Function<O,java.lang.String[]> rowMapper)

Method Detail

observeAsync

public void observeAsync(java.util.concurrent.CompletableFuture<O> futureObservation)

Specified by:

observeAsync in interface AsyncObserver<O extends Observation>

observe

public void observe(O observation)

Specified by:

observe in interface Observer<O extends Observation>

flushBuffer

public void flushBuffer()

Specified by:

flushBuffer in interface Buffering

isBufferNonEmpty

public boolean isBufferNonEmpty()

Specified by:

isBufferNonEmpty in interface Buffering

stop

public void stop()

Specified by:

stop in interface Stoppable

finalize

protected void finalize()
                 throws java.lang.Throwable

Overrides:

finalize in class java.lang.Object

Throws:

java.lang.Throwable