Package org.apache.cassandra.streaming

Interface StreamManagerMBean

All Superinterfaces:

NotificationBroadcaster, NotificationEmitter

All Known Implementing Classes:

StreamManager

public interface StreamManagerMBean
extends NotificationEmitter

Field Summary

Fields

Modifier and Type	Field	Description
static final String	OBJECT_NAME

Method Summary

Modifier and Type	Method	Description
Set<CompositeData>	getCurrentStreams()	Returns the current state of all ongoing streams.
String	getStreamingSlowEventsLogTimeout()
boolean	getStreamingStatsEnabled()
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.

Methods inherited from interface javax.management.NotificationBroadcaster

addNotificationListener, getNotificationInfo, removeNotificationListener

Methods inherited from interface javax.management.NotificationEmitter

removeNotificationListener

Field Details

OBJECT_NAME

static final String OBJECT_NAME

See Also:

• Constant Field Values

Method Details

getCurrentStreams

Set<CompositeData> getCurrentStreams()

Returns the current state of all ongoing streams.

getStreamingStatsEnabled

boolean getStreamingStatsEnabled()

Returns:

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

setStreamingStatsEnabled

void setStreamingStatsEnabled(boolean streamingStatsEnabled)

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

getStreamingSlowEventsLogTimeout

String getStreamingSlowEventsLogTimeout()

Returns:

current timeout for streaming slow events log

setStreamingSlowEventsLogTimeout

void setStreamingSlowEventsLogTimeout(String value)

Sets the timeout for the streaming slow events log