co.cask.cdap.data2.transaction.stream

Interface StreamConsumerFactory

All Known Implementing Classes:

AbstractStreamFileConsumerFactory, HBaseStreamFileConsumerFactory, InMemoryStreamConsumerFactory, LevelDBStreamFileConsumerFactory

public interface StreamConsumerFactory

Factory for creating StreamConsumer.

Method Summary

Methods

Modifier and Type	Method and Description
StreamConsumer	create(Id.Stream streamId, String namespace, ConsumerConfig consumerConfig) Creates a StreamConsumer.
void	dropAll(Id.Stream streamId, String namespace, Iterable<Long> groupIds) Deletes all consumer states for the given namespace and group ids.

Method Detail

create

StreamConsumer create(Id.Stream streamId,
                    String namespace,
                    ConsumerConfig consumerConfig)
                      throws IOException

Creates a StreamConsumer.

Parameters:

streamId - Id of the stream

namespace - application namespace for the state table.

consumerConfig - consumer configuration.

Returns:

a new instance of StreamConsumer.

Throws:

IOException

dropAll

void dropAll(Id.Stream streamId,
           String namespace,
           Iterable<Long> groupIds)
             throws IOException

Deletes all consumer states for the given namespace and group ids.

Parameters:

streamId - Id of the stream

namespace - application namespace for the state table.

groupIds - set of group id that needs to have states cleared.

Throws:

IOException