org.spf4j.perf.tsdb

Class TimeSeriesDatabase

java.lang.Object

org.spf4j.perf.tsdb.TimeSeriesDatabase

All Implemented Interfaces:

Closeable, AutoCloseable

public final class TimeSeriesDatabase
extends Object
implements Closeable

Yet another time series database. Why? because all the other ts databases had various constraints that restrict the functionality I can add to spf4j. Initial Features: 1. measurements can be added dynamically anytime to a database. 2. long measurement names. 3. the stored interval is not known from the beginning. 4. implementation biased towards write performance. Future thoughts:

Author:

zoly

Field Summary

Fields

Modifier and Type	Field and Description
static int	VERSION

Constructor Summary

Constructors

Constructor and Description
TimeSeriesDatabase(String pathToDatabaseFile, byte... metaData)

Method Summary

Methods

Modifier and Type	Method and Description
void	addTSTable(String tableName, byte[] tableMetaData, int sampleTime, String[] columnNames, byte[][] columnMetaData)
void	addTSTable(String tableName, byte[] tableMetaData, int sampleTime, String[] columnNames, String[] columnMetaData)
void	close()
static org.jfree.chart.JFreeChart	createCountJFreeChart(Pair<long[],long[][]> data, TSTable info)
org.jfree.chart.JFreeChart	createCountJFreeChart(String tableName)
org.jfree.chart.JFreeChart	createCountJFreeChart(String tableName, long startTime, long endTime)
static org.jfree.chart.JFreeChart	createHeatJFreeChart(Pair<long[],long[][]> data, TSTable info)
org.jfree.chart.JFreeChart	createHeatJFreeChart(String tableName)
org.jfree.chart.JFreeChart	createHeatJFreeChart(String tableName, long startTime, long endTime)
static List<org.jfree.chart.JFreeChart>	createJFreeCharts(Pair<long[],long[][]> data, TSTable info)
List<org.jfree.chart.JFreeChart>	createJFreeCharts(String tableName)
List<org.jfree.chart.JFreeChart>	createJFreeCharts(String tableName, long startTime, long endTime)
static org.jfree.chart.JFreeChart	createMinMaxAvgJFreeChart(Pair<long[],long[][]> data, TSTable info)
org.jfree.chart.JFreeChart	createMinMaxAvgJFreeChart(String tableName)
org.jfree.chart.JFreeChart	createMinMaxAvgJFreeChart(String tableName, long startTime, long endTime)
void	flush()
String[]	getColumnNames(String tableName)
String	getDBFilePath()
byte[]	getMetaData()
TSTable	getTSTable(String tableName)
Collection<TSTable>	getTSTables()
boolean	hasTSTable(String tableName)
Pair<long[],long[][]>	read(String tableName, long startTime, long endTime) Read measurements from table.
Pair<long[],long[][]>	readAll(String tableName)
long	readStartDate(String tableName)
String	toString()
void	write(long time, String tableName, long[] values)
void	writeCsvTable(String tableName, File output)
void	writeCsvTables(List<String> tableNames, File output)

Methods inherited from class java.lang.Object

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

Field Detail

VERSION

public static final int VERSION

See Also:

Constant Field Values

Constructor Detail

TimeSeriesDatabase

public TimeSeriesDatabase(String pathToDatabaseFile,
                  byte... metaData)
                   throws IOException

Throws:

IOException

Method Detail

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

hasTSTable

public boolean hasTSTable(String tableName)

addTSTable

public void addTSTable(String tableName,
              byte[] tableMetaData,
              int sampleTime,
              String[] columnNames,
              String[] columnMetaData)
                throws IOException

Throws:

IOException

addTSTable

public void addTSTable(String tableName,
              byte[] tableMetaData,
              int sampleTime,
              String[] columnNames,
              byte[][] columnMetaData)
                throws IOException

Throws:

IOException

write

public void write(long time,
         String tableName,
         long[] values)
           throws IOException

Throws:

IOException

flush

public void flush()
           throws IOException

Throws:

IOException

getColumnNames

public String[] getColumnNames(String tableName)

getTSTable

public TSTable getTSTable(String tableName)

getTSTables

public Collection<TSTable> getTSTables()

readAll

public Pair<long[],long[][]> readAll(String tableName)
                              throws IOException

Throws:

IOException

readStartDate

public long readStartDate(String tableName)
                   throws IOException

Throws:

IOException

read

public Pair<long[],long[][]> read(String tableName,
                         long startTime,
                         long endTime)
                           throws IOException

Read measurements from table.

Parameters:

tableName -

startTime - start time including

endTime - end time including

Returns:

Throws:

IOException

getDBFilePath

public String getDBFilePath()

createHeatJFreeChart

public org.jfree.chart.JFreeChart createHeatJFreeChart(String tableName)
                                                throws IOException

Throws:

IOException

createHeatJFreeChart

public org.jfree.chart.JFreeChart createHeatJFreeChart(String tableName,
                                              long startTime,
                                              long endTime)
                                                throws IOException

Throws:

IOException

createMinMaxAvgJFreeChart

public org.jfree.chart.JFreeChart createMinMaxAvgJFreeChart(String tableName)
                                                     throws IOException

Throws:

IOException

createMinMaxAvgJFreeChart

public org.jfree.chart.JFreeChart createMinMaxAvgJFreeChart(String tableName,
                                                   long startTime,
                                                   long endTime)
                                                     throws IOException

Throws:

IOException

createCountJFreeChart

public org.jfree.chart.JFreeChart createCountJFreeChart(String tableName)
                                                 throws IOException

Throws:

IOException

createCountJFreeChart

public org.jfree.chart.JFreeChart createCountJFreeChart(String tableName,
                                               long startTime,
                                               long endTime)
                                                 throws IOException

Throws:

IOException

createJFreeCharts

public List<org.jfree.chart.JFreeChart> createJFreeCharts(String tableName)
                                                   throws IOException

Throws:

IOException

createJFreeCharts

public List<org.jfree.chart.JFreeChart> createJFreeCharts(String tableName,
                                                 long startTime,
                                                 long endTime)
                                                   throws IOException

Throws:

IOException

createHeatJFreeChart

public static org.jfree.chart.JFreeChart createHeatJFreeChart(Pair<long[],long[][]> data,
                                              TSTable info)

createMinMaxAvgJFreeChart

public static org.jfree.chart.JFreeChart createMinMaxAvgJFreeChart(Pair<long[],long[][]> data,
                                                   TSTable info)

createCountJFreeChart

public static org.jfree.chart.JFreeChart createCountJFreeChart(Pair<long[],long[][]> data,
                                               TSTable info)

createJFreeCharts

public static List<org.jfree.chart.JFreeChart> createJFreeCharts(Pair<long[],long[][]> data,
                                                 TSTable info)

getMetaData

public byte[] getMetaData()

writeCsvTable

public void writeCsvTable(String tableName,
                 File output)
                   throws IOException

Throws:

IOException

writeCsvTables

public void writeCsvTables(List<String> tableNames,
                  File output)
                    throws IOException

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object