com.indeed.lsmtree.recordcache

Class RecordLogDirectoryPoller

java.lang.Object

com.indeed.lsmtree.recordlog.GenericRecordLogDirectoryPoller<Operation>

com.indeed.lsmtree.recordcache.RecordLogDirectoryPoller

All Implemented Interfaces:

Closeable, AutoCloseable, Runnable

public final class RecordLogDirectoryPoller
extends GenericRecordLogDirectoryPoller<Operation>

Author:

jplaisance

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	RecordLogDirectoryPoller.Functions Callback interface for processing record logs.

Constructor Summary

Constructors

Constructor and Description
RecordLogDirectoryPoller(RecordLogDirectory<Operation> recordLogDirectory, com.indeed.util.io.checkpointer.Checkpointer<Long> checkpointer)
RecordLogDirectoryPoller(RecordLogDirectory<Operation> recordLogDirectory, com.indeed.util.io.checkpointer.Checkpointer<Long> checkpointer, boolean loop)
RecordLogDirectoryPoller(RecordLogDirectory<Operation> recordLogDirectory, com.indeed.util.io.checkpointer.Checkpointer<Long> checkpointer, boolean loop, boolean deleteRecordLogs)
RecordLogDirectoryPoller(RecordLogDirectory<Operation> recordLogDirectory, File lastPositionFile)
RecordLogDirectoryPoller(RecordLogDirectory<Operation> recordLogDirectory, File lastPositionFile, boolean loop)
RecordLogDirectoryPoller(RecordLogDirectory<Operation> recordLogDirectory, File lastPositionFile, boolean loop, boolean deleteRecordLogs)

Method Summary

Methods inherited from class com.indeed.lsmtree.recordlog.GenericRecordLogDirectoryPoller

close, getCurrentSegmentNum, getCurrentSegmentTimestamp, getCurrentSegmentTimestring, getLastPosition, getMaxSegmentNum, getMaxSegmentTimestamp, getMaxSegmentTimestring, isAlive, registerFunctions, run, start

Methods inherited from class java.lang.Object

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

Constructor Detail

RecordLogDirectoryPoller

public RecordLogDirectoryPoller(RecordLogDirectory<Operation> recordLogDirectory,
                                File lastPositionFile)
                         throws IOException

Throws:

IOException

RecordLogDirectoryPoller

public RecordLogDirectoryPoller(RecordLogDirectory<Operation> recordLogDirectory,
                                File lastPositionFile,
                                boolean loop)
                         throws IOException

Throws:

IOException

RecordLogDirectoryPoller

public RecordLogDirectoryPoller(RecordLogDirectory<Operation> recordLogDirectory,
                                File lastPositionFile,
                                boolean loop,
                                boolean deleteRecordLogs)
                         throws IOException

Throws:

IOException

RecordLogDirectoryPoller

public RecordLogDirectoryPoller(RecordLogDirectory<Operation> recordLogDirectory,
                                com.indeed.util.io.checkpointer.Checkpointer<Long> checkpointer)
                         throws IOException

Throws:

IOException

RecordLogDirectoryPoller

public RecordLogDirectoryPoller(RecordLogDirectory<Operation> recordLogDirectory,
                                com.indeed.util.io.checkpointer.Checkpointer<Long> checkpointer,
                                boolean loop)
                         throws IOException

Throws:

IOException

RecordLogDirectoryPoller

public RecordLogDirectoryPoller(RecordLogDirectory<Operation> recordLogDirectory,
                                com.indeed.util.io.checkpointer.Checkpointer<Long> checkpointer,
                                boolean loop,
                                boolean deleteRecordLogs)
                         throws IOException

Parameters:

recordLogDirectory - record log directory

checkpointer - checkpointer

loop - If true, poller will continually poll for new record logs. If false only polls once.

deleteRecordLogs - If true, poller will delete record logs up to but excluding the most recently read one.

Throws:

IOException - if an I/O error occurs