co.cask.cdap.data.stream

Class InMemoryStreamCoordinatorClient

java.lang.Object

com.google.common.util.concurrent.AbstractIdleService

co.cask.cdap.data.stream.AbstractStreamCoordinatorClient

co.cask.cdap.data.stream.InMemoryStreamCoordinatorClient

All Implemented Interfaces:

StreamCoordinatorClient, com.google.common.util.concurrent.Service

public final class InMemoryStreamCoordinatorClient
extends AbstractStreamCoordinatorClient

In memory implementation for StreamCoordinatorClient.

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Constructor Summary

Constructors

Constructor and Description
InMemoryStreamCoordinatorClient()

Method Summary

Methods

Modifier and Type	Method and Description
protected <T> PropertyStore<T>	createPropertyStore(Codec<T> codec) Creates a PropertyStore.
protected void	doShutDown() Stops the service.
protected void	doStartUp() Starts the service.
protected Lock	getLock(Id.Stream streamId) Returns a Lock for performing exclusive operation for the given stream.
protected void	streamCreated(Id.Stream streamId) Gets invoked when a stream of the given name is created.
protected void	streamDeleted(Id.Stream streamId) Gets invoked when a stream is deleted.

Methods inherited from class co.cask.cdap.data.stream.AbstractStreamCoordinatorClient

addListener, createStream, deleteStream, exclusiveAction, shutDown, startUp, updateProperties

Methods inherited from class com.google.common.util.concurrent.AbstractIdleService

addListener, executor, isRunning, start, startAndWait, state, stop, stopAndWait, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.google.common.util.concurrent.Service

addListener, isRunning, start, startAndWait, state, stop, stopAndWait

Constructor Detail

InMemoryStreamCoordinatorClient

@Inject
public InMemoryStreamCoordinatorClient()

Method Detail

doStartUp

protected void doStartUp()
                  throws Exception

Description copied from class: AbstractStreamCoordinatorClient

Starts the service.

Specified by:

doStartUp in class AbstractStreamCoordinatorClient

Throws:

Exception - when starting of the service failed

doShutDown

protected void doShutDown()
                   throws Exception

Description copied from class: AbstractStreamCoordinatorClient

Stops the service.

Specified by:

doShutDown in class AbstractStreamCoordinatorClient

Throws:

Exception - when stopping the service could not be performed

createPropertyStore

protected <T> PropertyStore<T> createPropertyStore(Codec<T> codec)

Description copied from class: AbstractStreamCoordinatorClient

Creates a PropertyStore.

Specified by:

createPropertyStore in class AbstractStreamCoordinatorClient

Type Parameters:

T - Type of the property

Parameters:

codec - Codec for the property stored in the property store

Returns:

A new PropertyStore.

getLock

protected Lock getLock(Id.Stream streamId)

Description copied from class: AbstractStreamCoordinatorClient

Returns a Lock for performing exclusive operation for the given stream.

Specified by:

getLock in class AbstractStreamCoordinatorClient

streamCreated

protected void streamCreated(Id.Stream streamId)

Description copied from class: AbstractStreamCoordinatorClient

Gets invoked when a stream of the given name is created.

Specified by:

streamCreated in class AbstractStreamCoordinatorClient

streamDeleted

protected void streamDeleted(Id.Stream streamId)

Description copied from class: AbstractStreamCoordinatorClient

Gets invoked when a stream is deleted.

Specified by:

streamDeleted in class AbstractStreamCoordinatorClient