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

Class LevelDBStreamConsumerStateStoreFactory

java.lang.Object

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

All Implemented Interfaces:

StreamConsumerStateStoreFactory

public final class LevelDBStreamConsumerStateStoreFactory
extends Object
implements StreamConsumerStateStoreFactory

Factory for creating StreamConsumerStateStore in level db.

Method Summary

Methods

Modifier and Type	Method and Description
StreamConsumerStateStore	create(StreamConfig streamConfig) Creates a StreamConsumerStateStore for the given stream.
void	dropAllInNamespace(Id.Namespace namespace) Deletes all consumer state stores.

Methods inherited from class java.lang.Object

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

Method Detail

create

public StreamConsumerStateStore create(StreamConfig streamConfig)
                                throws IOException

Description copied from interface: StreamConsumerStateStoreFactory

Creates a StreamConsumerStateStore for the given stream.

Specified by:

create in interface StreamConsumerStateStoreFactory

Parameters:

streamConfig - Configuration of the stream.

Returns:

a new state store instance.

Throws:

IOException

dropAllInNamespace

public void dropAllInNamespace(Id.Namespace namespace)
                        throws IOException

Description copied from interface: StreamConsumerStateStoreFactory

Deletes all consumer state stores.

Specified by:

dropAllInNamespace in interface StreamConsumerStateStoreFactory

Throws:

IOException