co.cask.cdap.data2.transaction.stream

Interface StreamConsumerStateStoreFactory

All Known Implementing Classes:

HBaseStreamConsumerStateStoreFactory, InMemoryStreamConsumerStateStoreFactory, LevelDBStreamConsumerStateStoreFactory

public interface StreamConsumerStateStoreFactory

Factory for creating StreamConsumerStateStore instance for different streams.

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.

Method Detail

create

StreamConsumerStateStore create(StreamConfig streamConfig)
                                throws IOException

Creates a StreamConsumerStateStore for the given stream.

Parameters:

streamConfig - Configuration of the stream.

Returns:

a new state store instance.

Throws:

IOException

dropAllInNamespace

void dropAllInNamespace(Id.Namespace namespace)
                        throws IOException

Deletes all consumer state stores.

Throws:

IOException