public class WeightedSumMetric extends Metric
Modifier and Type | Field and Description |
---|---|
static String |
FUNC |
outputLong
Constructor and Description |
---|
WeightedSumMetric(StreamExpression expression,
StreamFactory factory) |
WeightedSumMetric(String valueCol,
String countCol) |
WeightedSumMetric(String valueCol,
String countCol,
boolean outputLong) |
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, toExplanation
public static final String FUNC
public WeightedSumMetric(StreamExpression expression, StreamFactory factory) throws IOException
IOException
public Metric newInstance()
newInstance
in class Metric
public String[] getColumns()
getColumns
in class Metric
public StreamExpressionParameter toExpression(StreamFactory factory) throws IOException
IOException
Copyright © 2000-2021 Apache Software Foundation. All Rights Reserved.