co.cask.cdap.data.stream

Class DistributedStreamCoordinatorClient

java.lang.Object

com.google.common.util.concurrent.AbstractIdleService

co.cask.cdap.data.stream.AbstractStreamCoordinatorClient

co.cask.cdap.data.stream.DistributedStreamCoordinatorClient

All Implemented Interfaces:

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

public final class DistributedStreamCoordinatorClient
extends AbstractStreamCoordinatorClient

A StreamCoordinatorClient uses ZooKeeper to implementation coordination needed for stream. It also uses a ResourceCoordinator to elect each handler as the leader of a set of streams.

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
DistributedStreamCoordinatorClient(ZKClient zkClient)

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

DistributedStreamCoordinatorClient

@Inject
public DistributedStreamCoordinatorClient(ZKClient zkClient)

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