Package org.processmining.specpp.supervision

Class DirectCSVWriter<O extends Observation>

java.lang.Object

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

All Implemented Interfaces:

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

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

Constructor Summary

Constructors

Constructor	Description
DirectCSVWriter(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	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 java.util.function.Consumer

andThen

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

accept

Constructor Detail

DirectCSVWriter

public DirectCSVWriter(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>

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