co.cask.cdap.data2.transaction.stream.inmemory

Class InMemoryStreamConsumerFactory

java.lang.Object

co.cask.cdap.data2.transaction.stream.inmemory.InMemoryStreamConsumerFactory

All Implemented Interfaces:

StreamConsumerFactory

public final class InMemoryStreamConsumerFactory
extends Object
implements StreamConsumerFactory

In memory implementation of StreamConsumer would be using the in memory queue implementation.

Constructor Summary

Constructors

Constructor and Description
InMemoryStreamConsumerFactory(QueueClientFactory queueClientFactory, InMemoryQueueService queueService)

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.

Methods inherited from class java.lang.Object

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

Constructor Detail

InMemoryStreamConsumerFactory

@Inject
public InMemoryStreamConsumerFactory(QueueClientFactory queueClientFactory,
                                    InMemoryQueueService queueService)

Method Detail

create

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

Description copied from interface: StreamConsumerFactory

Creates a StreamConsumer.

Specified by:

create in interface StreamConsumerFactory

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

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

Description copied from interface: StreamConsumerFactory

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

Specified by:

dropAll in interface StreamConsumerFactory

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