Package org.apache.cassandra.metrics

Class SamplingManager

java.lang.Object

org.apache.cassandra.metrics.SamplingManager

public class SamplingManager
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SamplingManager.ResultBuilder

Constructor Summary

Constructors

Constructor	Description
SamplingManager()

Method Summary

Modifier and Type	Method	Description
List<String>	allJobs()
static String	formatResult(SamplingManager.ResultBuilder resultBuilder)
static Iterable<ColumnFamilyStore>	getTables(String ks, String table)
boolean	register(String ks, String table, int duration, int interval, int capacity, int count, List<String> samplers)	Register the samplers for the keyspace and table.
boolean	unregister(String ks, String table)

Methods inherited from class java.lang.Object

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

Constructor Details

SamplingManager

public SamplingManager()

Method Details

formatResult

public static String formatResult(SamplingManager.ResultBuilder resultBuilder)

getTables

public static Iterable<ColumnFamilyStore> getTables(String ks,
 String table)

register

public boolean register(String ks,
 String table,
 int duration,
 int interval,
 int capacity,
 int count,
 List<String> samplers)

Register the samplers for the keyspace and table.

Parameters:

ks - Keyspace. Nullable. If null, the scheduled sampling is on all keyspaces and tables

table - Nullable. If null, the scheduled sampling is on all tables of the specified keyspace

duration - Duration of each scheduled sampling job in milliseconds

interval - Interval of each scheduled sampling job in milliseconds

capacity - Capacity of the sampler, higher for more accuracy

count - Number of the top samples to list

samplers - a list of samplers to enable

Returns:

true if the scheduled sampling is started successfully. Otherwise return fasle

unregister

public boolean unregister(String ks,
 String table)

allJobs

public List<String> allJobs()