org.spf4j.tsdb2

Class TSDBWriter

java.lang.Object

org.spf4j.tsdb2.TSDBWriter

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable

public final class TSDBWriter
extends Object
implements Closeable, Flushable

Second generation Time-Series database format. The linked list structure from first generation is dropped to reduce write overhead.

Author:

zoly

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.avro.Schema	FILE_RECORD_SCHEMA

Constructor Summary

Constructors

Constructor and Description
TSDBWriter(File file, int maxRowsPerBlock, String description, boolean append)

Method Summary

Modifier and Type	Method and Description
void	close()
void	flush() Commits the data to disk.
File	getFile()
Header	getHeader()
static void	toByteArray(long pvalue, byte[] bytes, int idx)
static void	toOutputStream(long pvalue, OutputStream os)
String	toString()
void	writeDataRow(long tableId, long timestamp, long... data)
long	writeTableDef(TableDef tableDef)

Methods inherited from class java.lang.Object

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

Field Detail

FILE_RECORD_SCHEMA

public static final org.apache.avro.Schema FILE_RECORD_SCHEMA

Constructor Detail

TSDBWriter

@CreatesObligation
public TSDBWriter(File file,
                                     int maxRowsPerBlock,
                                     String description,
                                     boolean append)
                              throws IOException

Throws:

IOException

Method Detail

writeTableDef

public long writeTableDef(TableDef tableDef)
                   throws IOException

Throws:

IOException

writeDataRow

public void writeDataRow(long tableId,
                         long timestamp,
                         long... data)
                  throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

getFile

public File getFile()

toByteArray

public static void toByteArray(long pvalue,
                               byte[] bytes,
                               int idx)

toOutputStream

public static void toOutputStream(long pvalue,
                                  OutputStream os)
                           throws IOException

Throws:

IOException

flush

public void flush()
           throws IOException

Commits the data to disk.

Specified by:

flush in interface Flushable

Throws:

IOException

getHeader

public Header getHeader()

toString

public String toString()

Overrides:

toString in class Object