co.cask.cdap.data2.transaction.stream.leveldb

Class LevelDBStreamFileConsumerFactory

java.lang.Object

co.cask.cdap.data2.transaction.stream.AbstractStreamFileConsumerFactory

co.cask.cdap.data2.transaction.stream.leveldb.LevelDBStreamFileConsumerFactory

All Implemented Interfaces:

StreamConsumerFactory

public final class LevelDBStreamFileConsumerFactory
extends AbstractStreamFileConsumerFactory

A StreamConsumerFactory that reads from stream file and uses LevelDB as the store for consumer process states.

Method Summary

Methods

Modifier and Type	Method and Description
protected StreamConsumer	create(TableId tableId, StreamConfig streamConfig, ConsumerConfig consumerConfig, StreamConsumerStateStore stateStore, StreamConsumerState beginConsumerState, FileReader<StreamEventOffset,Iterable<StreamFileOffset>> reader, ReadFilter extraFilter) Creates a StreamConsumer.
protected void	dropTable(TableId tableId) Deletes process states table.

Methods inherited from class co.cask.cdap.data2.transaction.stream.AbstractStreamFileConsumerFactory

create, dropAll, getFileOffsets

Methods inherited from class java.lang.Object

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

Method Detail

create

protected StreamConsumer create(TableId tableId,
                    StreamConfig streamConfig,
                    ConsumerConfig consumerConfig,
                    StreamConsumerStateStore stateStore,
                    StreamConsumerState beginConsumerState,
                    FileReader<StreamEventOffset,Iterable<StreamFileOffset>> reader,
                    @Nullable
                    ReadFilter extraFilter)
                         throws IOException

Description copied from class: AbstractStreamFileConsumerFactory

Creates a StreamConsumer.

Specified by:

create in class AbstractStreamFileConsumerFactory

Parameters:

tableId - Id of the table for storing process states

streamConfig - configuration of the stream to consume from

consumerConfig - configuration of the consumer

stateStore - The StreamConsumerStateStore for recording consumer state

reader - The FileReader to read stream events from

Returns:

A new instance of StreamConsumer

Throws:

IOException

dropTable

protected void dropTable(TableId tableId)
                  throws IOException

Description copied from class: AbstractStreamFileConsumerFactory

Deletes process states table.

Specified by:

dropTable in class AbstractStreamFileConsumerFactory

Parameters:

tableId - Id of the process states table.

Throws:

IOException