public class CorrelationEvaluator extends ComplexEvaluator implements Expressible
constructingFactory, nodeId, streamContext, subEvaluators| Constructor and Description |
|---|
CorrelationEvaluator(StreamExpression expression,
StreamFactory factory) |
| Modifier and Type | Method and Description |
|---|---|
Number |
evaluate(Tuple tuple) |
Explanation |
toExplanation(StreamFactory factory)
Returns an explanation about the stream object
|
StreamExpressionParameter |
toExpression(StreamFactory factory) |
getStreamContext, setStreamContextclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitevaluateOverContextpublic CorrelationEvaluator(StreamExpression expression, StreamFactory factory) throws IOException
IOExceptionpublic Number evaluate(Tuple tuple) throws IOException
evaluate in interface StreamEvaluatorIOExceptionpublic StreamExpressionParameter toExpression(StreamFactory factory) throws IOException
toExpression in interface ExpressibletoExpression in class ComplexEvaluatorIOExceptionpublic Explanation toExplanation(StreamFactory factory) throws IOException
ExpressibletoExplanation in interface ExpressibletoExplanation in class ComplexEvaluatorfactory - Stream factory for this, contains information about the function nameIOException - throw on any errorCopyright © 2000-2017 Apache Software Foundation. All Rights Reserved.