org.spf4j.tsdb2

Class TSDBReader

java.lang.Object

org.spf4j.tsdb2.TSDBReader

All Implemented Interfaces:

Closeable, AutoCloseable

public final class TSDBReader
extends Object
implements Closeable

Author:

zoly

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TSDBReader.EventSensitivity

Constructor Summary

Constructors

Constructor and Description
TSDBReader(File file, int bufferSize)

Method Summary

Modifier and Type	Method and Description
<E extends Exception> Future<Void>	bgWatch(Handler<Either<TableDef,DataBlock>,E> handler, TSDBReader.EventSensitivity es)
<E extends Exception> Future<Void>	bgWatch(Handler<Either<TableDef,DataBlock>,E> handler, TSDBReader.EventSensitivity es, long deadlineNanos)
<E extends Exception> Future<Void>	bgWatch(Handler<Either<TableDef,DataBlock>,E> handler, TSDBReader.EventSensitivity es, long timeout, TimeUnit unit)
void	close()
Header	getHeader()
long	getSize()
Either<TableDef,DataBlock>	read()
void	readAll(Consumer<Either<TableDef,DataBlock>> consumer)
<E extends Exception> void	readAll(Handler<Either<TableDef,DataBlock>,E> handler, long deadlineNanos)
boolean	reReadSize() method useful when implementing tailing.
void	stopWatching()
String	toString()
<E extends Exception> void	watch(Handler<Either<TableDef,DataBlock>,E> handler, TSDBReader.EventSensitivity es)
<E extends Exception> void	watch(Handler<Either<TableDef,DataBlock>,E> handler, TSDBReader.EventSensitivity es, long deadlineNanos)
<E extends Exception> void	watch(Handler<Either<TableDef,DataBlock>,E> handler, TSDBReader.EventSensitivity es, long timeout, TimeUnit unit)

Methods inherited from class java.lang.Object

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

Constructor Detail

TSDBReader

public TSDBReader(File file,
                  int bufferSize)
           throws IOException

Throws:

IOException

Method Detail

reReadSize

public boolean reReadSize()
                   throws IOException

method useful when implementing tailing.

Returns:

true if size changed.

Throws:

IOException

read

@Nullable
public Either<TableDef,DataBlock> read()
                                          throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

getSize

public long getSize()

getHeader

public Header getHeader()

stopWatching

public void stopWatching()

bgWatch

public <E extends Exception> Future<Void> bgWatch(Handler<Either<TableDef,DataBlock>,E> handler,
                                                  TSDBReader.EventSensitivity es)

bgWatch

public <E extends Exception> Future<Void> bgWatch(Handler<Either<TableDef,DataBlock>,E> handler,
                                                  TSDBReader.EventSensitivity es,
                                                  long timeout,
                                                  TimeUnit unit)

bgWatch

public <E extends Exception> Future<Void> bgWatch(Handler<Either<TableDef,DataBlock>,E> handler,
                                                  TSDBReader.EventSensitivity es,
                                                  long deadlineNanos)

watch

public <E extends Exception> void watch(Handler<Either<TableDef,DataBlock>,E> handler,
                                        TSDBReader.EventSensitivity es)
                                 throws IOException,
                                        InterruptedException,
                                        E extends Exception

Throws:

IOException

InterruptedException

E extends Exception

watch

public <E extends Exception> void watch(Handler<Either<TableDef,DataBlock>,E> handler,
                                        TSDBReader.EventSensitivity es,
                                        long timeout,
                                        TimeUnit unit)
                                 throws IOException,
                                        InterruptedException,
                                        E extends Exception

Throws:

IOException

InterruptedException

E extends Exception

watch

public <E extends Exception> void watch(Handler<Either<TableDef,DataBlock>,E> handler,
                                        TSDBReader.EventSensitivity es,
                                        long deadlineNanos)
                                 throws IOException,
                                        InterruptedException,
                                        E extends Exception

Throws:

IOException

InterruptedException

E extends Exception

readAll

public <E extends Exception> void readAll(Handler<Either<TableDef,DataBlock>,E> handler,
                                          long deadlineNanos)
                                   throws IOException,
                                          E extends Exception

Throws:

IOException

E extends Exception

readAll

public void readAll(Consumer<Either<TableDef,DataBlock>> consumer)
             throws IOException

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object