Package io.github.ai4ci.flow

Class StateExporter

java.lang.Object

io.github.ai4ci.flow.StateExporter

All Implemented Interfaces:

Closeable, AutoCloseable

public class StateExporter
extends Object
implements Closeable

This manages the various files that are being exported to so and their respective threads that the outbreak simulation doesn't have to. It has a single method, export(outbreak, stage), that is called at the different lifecycle

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	StateExporter.ExportSelector<X extends CSVWriter.Writeable>

Method Summary

Modifier and Type	Method	Description
boolean	allWaiting()
void	close()
<X extends CSVWriter.Writeable> Outbreak	export(Outbreak outbreak)
<X extends CSVWriter.Writeable> Outbreak	export(Export.Stage stage, Outbreak outbreak)
void	finalise(Outbreak outbreak)
void	joinAll()
static StateExporter	of(Path directory, StateExporter.ExportSelector<?>... config)
static StateExporter	of(Path directory, List<StateExporter.ExportSelector<?>> config)
protected String	report()
void	writeInputConfiguration(ExperimentConfiguration tmp)

Methods inherited from class java.lang.Object

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

Method Details

of

public static StateExporter of(Path directory,
 StateExporter.ExportSelector<?>... config)

of

public static StateExporter of(Path directory,
 List<StateExporter.ExportSelector<?>> config)

export

public <X extends CSVWriter.Writeable> Outbreak export(Outbreak outbreak)

export

public <X extends CSVWriter.Writeable> Outbreak export(Export.Stage stage,
 Outbreak outbreak)

allWaiting

public boolean allWaiting()

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

finalise

public void finalise(Outbreak outbreak)

writeInputConfiguration

public void writeInputConfiguration(ExperimentConfiguration tmp)

joinAll

public void joinAll()
             throws InterruptedException

Throws:

InterruptedException

report

protected String report()