Package org.apache.cassandra.streaming

Class StreamManager

java.lang.Object

org.apache.cassandra.streaming.StreamManager

All Implemented Interfaces:

NotificationBroadcaster, NotificationEmitter, StreamManagerMBean

public class StreamManager
extends Object
implements StreamManagerMBean

StreamManager manages currently running StreamResultFutures and provides status of all operation invoked. All stream operations should be created through this class to track streaming status and progress.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	StreamManager.StreamListener
static class	StreamManager.StreamRateLimiter

Field Summary

Fields

Modifier and Type	Field	Description
static final StreamManager	instance

Fields inherited from interface org.apache.cassandra.streaming.StreamManagerMBean

OBJECT_NAME

Constructor Summary

Constructors

Constructor	Description
StreamManager()

Method Summary

Modifier and Type	Method	Description
void	addListener(StreamManager.StreamListener listener)
void	addNotificationListener(NotificationListener listener, NotificationFilter filter, Object handback)
protected void	addStreamingStateAgain(StreamingState state)
void	clearStates()
StreamSession	findSession(InetAddressAndPort peer, TimeUUID planId, int sessionIndex, boolean searchInitiatorSessions)
Set<CompositeData>	getCurrentStreams()	Returns the current state of all ongoing streams.
static StreamManager.StreamRateLimiter	getEntireSSTableRateLimiter(InetAddressAndPort peer)	Get streaming rate limiter for entire SSTable operations.
StreamResultFuture	getInitiatorStream(TimeUUID planId)
MBeanNotificationInfo[]	getNotificationInfo()
static StreamManager.StreamRateLimiter	getRateLimiter(InetAddressAndPort peer)	Gets streaming rate limiter.
StreamResultFuture	getReceivingStream(TimeUUID planId)
String	getStreamingSlowEventsLogTimeout()
StreamingState	getStreamingState(TimeUUID id)
Collection<StreamingState>	getStreamingStates()
boolean	getStreamingStatsEnabled()
long	getTotalRemainingOngoingBytes()
void	putFollowerStream(StreamResultFuture future)
void	putInitiatorStream(StreamResultFuture future)
void	putStreamingState(StreamingState state)
StreamResultFuture	registerFollower(StreamResultFuture result)
void	registerInitiator(StreamResultFuture result)
void	removeListener(StreamManager.StreamListener listener)
void	removeNotificationListener(NotificationListener listener)
void	removeNotificationListener(NotificationListener listener, NotificationFilter filter, Object handback)
void	setStreamingSlowEventsLogTimeout(String value)	Sets the timeout for the streaming slow events log
void	setStreamingStatsEnabled(boolean streamingStatsEnabled)	enable/disable collection of streaming stats while streaming is running.
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Details

instance

public static final StreamManager instance

Constructor Details

StreamManager

public StreamManager()

Method Details

getRateLimiter

public static StreamManager.StreamRateLimiter getRateLimiter(InetAddressAndPort peer)

Gets streaming rate limiter. When stream_throughput_outbound is 0, this returns rate limiter with the rate of Double.MAX_VALUE bytes per second. Rate unit is bytes per sec.

Returns:

StreamRateLimiter with rate limit set based on peer location.

getEntireSSTableRateLimiter

public static StreamManager.StreamRateLimiter getEntireSSTableRateLimiter(InetAddressAndPort peer)

Get streaming rate limiter for entire SSTable operations. When entire_sstable_stream_throughput_outbound is less than or equal ot 0, this returns rate limiter with the rate of Double.MAX_VALUE bytes per second. Rate unit is bytes per sec.

Parameters:

peer - the peer location

Returns:

StreamManager.StreamRateLimiter with entire SSTable rate limit set based on peer location

addStreamingStateAgain

protected void addStreamingStateAgain(StreamingState state)

start

public void start()

stop

public void stop()

getStreamingStates

public Collection<StreamingState> getStreamingStates()

getStreamingState

public StreamingState getStreamingState(TimeUUID id)

putStreamingState

public void putStreamingState(StreamingState state)

clearStates

public void clearStates()

getCurrentStreams

public Set<CompositeData> getCurrentStreams()

Description copied from interface: StreamManagerMBean

Returns the current state of all ongoing streams.

Specified by:

getCurrentStreams in interface StreamManagerMBean

getStreamingStatsEnabled

public boolean getStreamingStatsEnabled()

Specified by:

getStreamingStatsEnabled in interface StreamManagerMBean

Returns:

whether the streaming virtual table should collect stats while streaming is running

setStreamingStatsEnabled

public void setStreamingStatsEnabled(boolean streamingStatsEnabled)

Description copied from interface: StreamManagerMBean

enable/disable collection of streaming stats while streaming is running.

Specified by:

setStreamingStatsEnabled in interface StreamManagerMBean

getStreamingSlowEventsLogTimeout

public String getStreamingSlowEventsLogTimeout()

Specified by:

getStreamingSlowEventsLogTimeout in interface StreamManagerMBean

Returns:

current timeout for streaming slow events log

setStreamingSlowEventsLogTimeout

public void setStreamingSlowEventsLogTimeout(String value)

Description copied from interface: StreamManagerMBean

Sets the timeout for the streaming slow events log

Specified by:

setStreamingSlowEventsLogTimeout in interface StreamManagerMBean

registerInitiator

public void registerInitiator(StreamResultFuture result)

registerFollower

public StreamResultFuture registerFollower(StreamResultFuture result)

putInitiatorStream

public void putInitiatorStream(StreamResultFuture future)

putFollowerStream

public void putFollowerStream(StreamResultFuture future)

addListener

public void addListener(StreamManager.StreamListener listener)

removeListener

public void removeListener(StreamManager.StreamListener listener)

getReceivingStream

public StreamResultFuture getReceivingStream(TimeUUID planId)

getInitiatorStream

public StreamResultFuture getInitiatorStream(TimeUUID planId)

addNotificationListener

public void addNotificationListener(NotificationListener listener,
 NotificationFilter filter,
 Object handback)

Specified by:

addNotificationListener in interface NotificationBroadcaster

removeNotificationListener

public void removeNotificationListener(NotificationListener listener)
                                throws ListenerNotFoundException

Specified by:

removeNotificationListener in interface NotificationBroadcaster

Throws:

ListenerNotFoundException

removeNotificationListener

public void removeNotificationListener(NotificationListener listener,
 NotificationFilter filter,
 Object handback)
                                throws ListenerNotFoundException

Specified by:

removeNotificationListener in interface NotificationEmitter

Throws:

ListenerNotFoundException

getNotificationInfo

public MBeanNotificationInfo[] getNotificationInfo()

Specified by:

getNotificationInfo in interface NotificationBroadcaster

findSession

public StreamSession findSession(InetAddressAndPort peer,
 TimeUUID planId,
 int sessionIndex,
 boolean searchInitiatorSessions)

getTotalRemainingOngoingBytes

public long getTotalRemainingOngoingBytes()