public class SumMetric extends Metric
| Constructor and Description |
|---|
SumMetric(StreamExpression expression,
StreamFactory factory) |
SumMetric(String columnName) |
| Modifier and Type | Method and Description |
|---|---|
String[] |
getColumns() |
Number |
getValue() |
Metric |
newInstance() |
StreamExpressionParameter |
toExpression(StreamFactory factory) |
void |
update(Tuple tuple) |
getFunctionName, getIdentifier, getMetricNodeId, setFunctionName, setIdentifier, setIdentifier, toExplanationpublic SumMetric(String columnName)
public SumMetric(StreamExpression expression, StreamFactory factory) throws IOException
IOExceptionpublic String[] getColumns()
getColumns in class Metricpublic Metric newInstance()
newInstance in class Metricpublic StreamExpressionParameter toExpression(StreamFactory factory) throws IOException
IOExceptionCopyright © 2000-2016 Apache Software Foundation. All Rights Reserved.