org.apache.hadoop.chukwa.datastore

Class ChukwaHBaseStore

java.lang.Object

org.apache.hadoop.chukwa.datastore.ChukwaHBaseStore

public class ChukwaHBaseStore
extends Object

Constructor Summary

Constructors

Constructor and Description
ChukwaHBaseStore()

Method Summary

Modifier and Type	Method and Description
static void	closeHBase()
static String	createChart(Chart chart) Create a chart in HBase.
static String	createChart(String id, String title, String[] metrics, String source, String yunitType) Create a chart in HBase by specifying parameters.
static String	createCircle(String id, String title, String[] metrics, String source, String suffixLabel, String direction) Create a chart in HBase by specifying parameters.
static String	createTile(String id, String title, String bannerText, String suffixLabel, String[] metrics, String source, String icon) Create a tile in HBase by specifying parameters.
static boolean	createWidget(Widget widget) Create a widget in HBase.
static boolean	deleteWidget(String title) Delete a widget in HBase.
static Chart	getChart(String id) Get a chart from HBase by ID.
static ArrayList<SeriesMetaData>	getChartSeries(ArrayList<SeriesMetaData> series, long startTime, long endTime) Return data for multiple series of metrics stored in HBase.
static Set<String>	getClusterNames(long startTime, long endTime) Scan chukwa table and find cluster tag from annotation column family from a range of entries.
static Dashboard	getDashboard(String id, String user)
static List<String>	getData(ArrayList<SeriesMetaData> series, long startTime, long endTime)
static void	getHBaseConnection()
static Heatmap	getHeatmap(String metricGroup, String metric, long startTime, long endTime, double max, double scale, int width, int height)
static Set<String>	getMetricGroups()
static Set<String>	getMetricNames(String metricGroup)
static Series	getSeries(String metric, String source, long startTime, long endTime) Scan chukwa table for a full metric name based on time ranges.
static Series	getSeries(String metricGroup, String metric, String source, long startTime, long endTime) Scan chukwa table for a particular metric group and metric name based on time ranges.
static Set<String>	getSourceNames(String dataType)
static boolean	isDefaultExists()
static List<Widget>	listWidget(int limit, int offset) List widgets stored in HBase.
static void	populateDefaults()
static void	putChart(String id, Chart chart) Update a chart in HBase by ID.
static List<Widget>	searchWidget(String query) Find widget by title prefix in HBase.
static boolean	updateDashboard(String id, String user, Dashboard dash)
static boolean	updateWidget(String title, Widget widget) Update a widget in HBase.
static Widget	viewWidget(String title) View a widget information in HBase.

Methods inherited from class java.lang.Object

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

Constructor Detail

ChukwaHBaseStore

public ChukwaHBaseStore()

Method Detail

getHBaseConnection

public static void getHBaseConnection()
                               throws IOException

Throws:

IOException

closeHBase

public static void closeHBase()

getSeries

public static Series getSeries(String metricGroup,
                               String metric,
                               String source,
                               long startTime,
                               long endTime)

Scan chukwa table for a particular metric group and metric name based on time ranges.

Parameters:

metricGroup -

metric -

source -

startTime -

endTime -

Returns:

Series

getSeries

public static Series getSeries(String metric,
                               String source,
                               long startTime,
                               long endTime)

Scan chukwa table for a full metric name based on time ranges.

Parameters:

metric -

source -

startTime -

endTime -

Returns:

Series

getMetricNames

public static Set<String> getMetricNames(String metricGroup)

getMetricGroups

public static Set<String> getMetricGroups()

getSourceNames

public static Set<String> getSourceNames(String dataType)

getHeatmap

public static Heatmap getHeatmap(String metricGroup,
                                 String metric,
                                 long startTime,
                                 long endTime,
                                 double max,
                                 double scale,
                                 int width,
                                 int height)

getClusterNames

public static Set<String> getClusterNames(long startTime,
                                          long endTime)

Scan chukwa table and find cluster tag from annotation column family from a range of entries.

Parameters:

startTime -

endTime -

Returns:

Set of cluster names

getChart

public static Chart getChart(String id)

Get a chart from HBase by ID.

Parameters:

id -

Returns:

Chart

putChart

public static void putChart(String id,
                            Chart chart)

Update a chart in HBase by ID.

Parameters:

id -

chart -

createChart

public static String createChart(String id,
                                 String title,
                                 String[] metrics,
                                 String source,
                                 String yunitType)
                          throws URISyntaxException

Create a chart in HBase by specifying parameters.

Parameters:

id -

title -

metrics -

source -

yunitType -

Returns:

Throws:

URISyntaxException

createCircle

public static String createCircle(String id,
                                  String title,
                                  String[] metrics,
                                  String source,
                                  String suffixLabel,
                                  String direction)
                           throws URISyntaxException

Create a chart in HBase by specifying parameters.

Parameters:

id -

title -

metrics -

source -

suffixLabel -

direction -

Returns:

Throws:

URISyntaxException

createTile

public static String createTile(String id,
                                String title,
                                String bannerText,
                                String suffixLabel,
                                String[] metrics,
                                String source,
                                String icon)
                         throws URISyntaxException

Create a tile in HBase by specifying parameters.

Parameters:

id -

title -

bannerText -

suffixLabel -

metrics -

source -

icon -

Returns:

html

Throws:

URISyntaxException

createChart

public static String createChart(Chart chart)

Create a chart in HBase.

Parameters:

chart -

Returns:

id of newly created chart

getChartSeries

public static ArrayList<SeriesMetaData> getChartSeries(ArrayList<SeriesMetaData> series,
                                                       long startTime,
                                                       long endTime)

Return data for multiple series of metrics stored in HBase.

Parameters:

series -

startTime -

endTime -

Returns:

List of series meta data

listWidget

public static List<Widget> listWidget(int limit,
                                      int offset)

List widgets stored in HBase.

Parameters:

limit -

offset -

Returns:

List of widgets

getData

public static List<String> getData(ArrayList<SeriesMetaData> series,
                                   long startTime,
                                   long endTime)

searchWidget

public static List<Widget> searchWidget(String query)

Find widget by title prefix in HBase.

Parameters:

query - - Prefix query of widget title.

Returns:

List of widgets

viewWidget

public static Widget viewWidget(String title)

View a widget information in HBase.

Parameters:

title - - Title of the widget.

Returns:

Widget

createWidget

public static boolean createWidget(Widget widget)

Create a widget in HBase.

Parameters:

widget -

Returns:

updateWidget

public static boolean updateWidget(String title,
                                   Widget widget)

Update a widget in HBase.

Parameters:

title -

widget -

Returns:

deleteWidget

public static boolean deleteWidget(String title)

Delete a widget in HBase.

Parameters:

title -

Returns:

isDefaultExists

public static boolean isDefaultExists()

populateDefaults

public static void populateDefaults()

getDashboard

public static Dashboard getDashboard(String id,
                                     String user)

updateDashboard

public static boolean updateDashboard(String id,
                                      String user,
                                      Dashboard dash)