co.cask.cdap.messaging.store.leveldb

Class LevelDBPayloadTable

java.lang.Object

co.cask.cdap.messaging.store.AbstractPayloadTable

co.cask.cdap.messaging.store.leveldb.LevelDBPayloadTable

All Implemented Interfaces:

PayloadTable, Closeable, AutoCloseable

public class LevelDBPayloadTable
extends AbstractPayloadTable

LevelDB implementation of PayloadTable.

Nested Class Summary

Nested classes/interfaces inherited from interface co.cask.cdap.messaging.store.PayloadTable

PayloadTable.Entry

Constructor Summary

Constructors

Constructor and Description
LevelDBPayloadTable(org.iq80.leveldb.DB levelDB)

Method Summary

Modifier and Type	Method and Description
void	close()
void	persist(Iterator<RawPayloadTableEntry> entries) Store the RawPayloadTableEntrys persistently.
void	pruneMessages(TopicMetadata topicMetadata, long currentTime) Delete messages of a TopicId that has exceeded the TTL or if it belongs to an older generation
protected co.cask.cdap.api.dataset.lib.CloseableIterator<RawPayloadTableEntry>	read(byte[] startRow, byte[] stopRow, int limit) Read the RawPayloadTableEntrys given a key range.

Methods inherited from class co.cask.cdap.messaging.store.AbstractPayloadTable

fetch, store

Methods inherited from class java.lang.Object

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

Constructor Detail

LevelDBPayloadTable

public LevelDBPayloadTable(org.iq80.leveldb.DB levelDB)

Method Detail

read

protected co.cask.cdap.api.dataset.lib.CloseableIterator<RawPayloadTableEntry> read(byte[] startRow,
                                                                                    byte[] stopRow,
                                                                                    int limit)
                                                                             throws IOException

Description copied from class: AbstractPayloadTable

Read the RawPayloadTableEntrys given a key range.

Specified by:

read in class AbstractPayloadTable

Parameters:

startRow - start row prefix

stopRow - stop row prefix

limit - maximum number of messages to read

Returns:

CloseableIterator of RawPayloadTableEntrys

Throws:

IOException - thrown if there was an error while trying to read the entries from the table

persist

public void persist(Iterator<RawPayloadTableEntry> entries)
             throws IOException

Description copied from class: AbstractPayloadTable

Store the RawPayloadTableEntrys persistently.

Specified by:

persist in class AbstractPayloadTable

Parameters:

entries - Iterator of RawPayloadTableEntrys

Throws:

IOException - thrown if there was an error while storing the entries

pruneMessages

public void pruneMessages(TopicMetadata topicMetadata,
                          long currentTime)
                   throws IOException

Delete messages of a TopicId that has exceeded the TTL or if it belongs to an older generation

Parameters:

topicMetadata - TopicMetadata

currentTime - current timestamp

Throws:

IOException - error occurred while trying to delete a row in LevelDB

close

public void close()
           throws IOException

Throws:

IOException