co.cask.cdap.data.stream

Class StreamPropertyListener

java.lang.Object

co.cask.cdap.data.stream.StreamPropertyListener

public abstract class StreamPropertyListener
extends Object

Listener for changes in stream properties.

Constructor Summary

Constructors

Constructor and Description
StreamPropertyListener()

Method Summary

Methods

Modifier and Type	Method and Description
void	deleted(Id.Stream streamId) Invoked when the stream property is deleted.
void	generationChanged(Id.Stream streamId, int generation) Invoked when stream generation changed.
void	thresholdChanged(Id.Stream streamId, int threshold) Invoked when the stream Notification threshold property is changed.
void	ttlChanged(Id.Stream streamId, long ttl) Invoked when the stream TTL property is changed.

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamPropertyListener

public StreamPropertyListener()

Method Detail

generationChanged

public void generationChanged(Id.Stream streamId,
                     int generation)

Invoked when stream generation changed. Generation only increase monotonically, hence this method is guaranteed to see only increasing generation across multiple calls.

Parameters:

streamId - Id of the stream

generation - The generation id updated to.

ttlChanged

public void ttlChanged(Id.Stream streamId,
              long ttl)

Invoked when the stream TTL property is changed.

Parameters:

streamId - Id of the stream

ttl - TTL of the stream

thresholdChanged

public void thresholdChanged(Id.Stream streamId,
                    int threshold)

Invoked when the stream Notification threshold property is changed.

Parameters:

streamId - Id of the stream

threshold - Notification threshold of the stream

deleted

public void deleted(Id.Stream streamId)

Invoked when the stream property is deleted.

Parameters:

streamId - Id of the stream