public class

AlertProcessor

extends Object
java.lang.Object
   ↳ org.apache.helix.alerts.AlertProcessor

Summary

Constants
String noWildcardAlertKey
Public Constructors
AlertProcessor(StatsHolder sh)
Public Methods
static List<Iterator<Tuple<String>>> convertTupleRowsToTupleColumns(Map<String, ArrayList<Tuple<String>>> tupleMap)
static HashMap<String, AlertValueAndStatus> executeAlert(Alert alert, List<Stat> persistedStats)
static Map<String, Map<String, AlertValueAndStatus>> executeAllAlerts(List<Alert> alerts, List<Stat> stats)
static ArrayList<AlertValueAndStatus> executeComparator(Iterator<Tuple<String>> tuples, String comparatorName, Tuple<String> constant)
static Iterator<Tuple<String>> executeOperatorPipeline(List<Iterator<Tuple<String>>> tupleIters, String[] operators)
static String formAlertKey(ArrayList<String> bindings)
static HashMap<String, AlertValueAndStatus> generateResultMap(Set<String> alertStatBindings, ArrayList<AlertValueAndStatus> evalResults)
static Map<String, List<Tuple<String>>> initAlertStatTuples(Alert alert)
static Map<String, ArrayList<Tuple<String>>> populateAlertStatTuples(String[] alertStats, List<Stat> persistentStats)
[Expand]
Inherited Methods
From class java.lang.Object

Constants

public static final String noWildcardAlertKey

Constant Value: "*"

Public Constructors

public AlertProcessor (StatsHolder sh)

Public Methods

public static List<Iterator<Tuple<String>>> convertTupleRowsToTupleColumns (Map<String, ArrayList<Tuple<String>>> tupleMap)

public static HashMap<String, AlertValueAndStatus> executeAlert (Alert alert, List<Stat> persistedStats)

public static Map<String, Map<String, AlertValueAndStatus>> executeAllAlerts (List<Alert> alerts, List<Stat> stats)

public static ArrayList<AlertValueAndStatus> executeComparator (Iterator<Tuple<String>> tuples, String comparatorName, Tuple<String> constant)

public static Iterator<Tuple<String>> executeOperatorPipeline (List<Iterator<Tuple<String>>> tupleIters, String[] operators)

public static String formAlertKey (ArrayList<String> bindings)

public static HashMap<String, AlertValueAndStatus> generateResultMap (Set<String> alertStatBindings, ArrayList<AlertValueAndStatus> evalResults)

public static Map<String, List<Tuple<String>>> initAlertStatTuples (Alert alert)

public static Map<String, ArrayList<Tuple<String>>> populateAlertStatTuples (String[] alertStats, List<Stat> persistentStats)