org.spf4j.tsdb2

Class TSDBQuery

java.lang.Object

org.spf4j.tsdb2.TSDBQuery

public final class TSDBQuery
extends Object

Author:

zoly

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TSDBQuery.TableDefEx

Method Summary

Modifier and Type	Method and Description
static com.google.common.collect.ListMultimap<String,TableDef>	getAllTables(File tsdbFile)
static com.google.common.collect.ListMultimap<String,TSDBQuery.TableDefEx>	getAllTablesWithDataRanges(File tsdbFile)
static ColumnDef	getColumnDef(TableDef td, String columnName)
static ColumnDef	getColumnDefIfExists(TableDef td, String columnName)
static int	getColumnIndex(TableDef td, String columnName)
static String[]	getColumnNames(TableDef td)
static String[]	getColumnUnitsOfMeasurement(TableDef td)
static long[]	getIds(Collection<TableDef> tableDefs)
static List<TableDef>	getTableDef(File tsdbFile, String tableName)
static com.google.common.collect.ListMultimap<String,TableDef>	getTables(File tsdbFile, Set<String> tables)
static TimeSeries	getTimeSeries(File tsdbFile, long[] tableIds, long startTimeMillis, long endTimeMillis)
static void	writeAsCsv(Appendable writer, File tsDB, String tableName)
static void	writeCsvTable(File tsDB, String tableName, File output)
static void	writeCsvTables(File tsDB, Set<String> tableNames, File output)

Methods inherited from class java.lang.Object

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

Method Detail

getAllTables

public static com.google.common.collect.ListMultimap<String,TableDef> getAllTables(File tsdbFile)
                                                                            throws IOException

Throws:

IOException

getTables

public static com.google.common.collect.ListMultimap<String,TableDef> getTables(File tsdbFile,
                                                                                Set<String> tables)
                                                                         throws IOException

Throws:

IOException

getAllTablesWithDataRanges

public static com.google.common.collect.ListMultimap<String,TSDBQuery.TableDefEx> getAllTablesWithDataRanges(File tsdbFile)
                                                                                                      throws IOException

Throws:

IOException

getTableDef

@Nonnull
public static List<TableDef> getTableDef(File tsdbFile,
                                                  String tableName)
                                           throws IOException

Throws:

IOException

getTimeSeries

public static TimeSeries getTimeSeries(File tsdbFile,
                                       long[] tableIds,
                                       long startTimeMillis,
                                       long endTimeMillis)
                                throws IOException

Throws:

IOException

getIds

public static long[] getIds(Collection<TableDef> tableDefs)

writeCsvTable

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

Throws:

IOException

writeAsCsv

public static void writeAsCsv(Appendable writer,
                              File tsDB,
                              String tableName)
                       throws IOException

Throws:

IOException

writeCsvTables

public static void writeCsvTables(File tsDB,
                                  Set<String> tableNames,
                                  File output)
                           throws IOException

Throws:

IOException

getColumnDefIfExists

@Nullable
public static ColumnDef getColumnDefIfExists(TableDef td,
                                                       String columnName)

getColumnDef

@Nonnull
public static ColumnDef getColumnDef(TableDef td,
                                              String columnName)

getColumnIndex

public static int getColumnIndex(TableDef td,
                                 String columnName)

getColumnNames

public static String[] getColumnNames(TableDef td)

getColumnUnitsOfMeasurement

public static String[] getColumnUnitsOfMeasurement(TableDef td)