public class AnalyzeEvaluator extends SimpleEvaluator
nodeId, streamContext| Constructor and Description |
|---|
AnalyzeEvaluator(StreamExpression expression,
StreamFactory factory) |
AnalyzeEvaluator(String _fieldName,
String _analyzerField) |
| Modifier and Type | Method and Description |
|---|---|
Object |
evaluate(Tuple tuple) |
void |
setStreamContext(StreamContext context) |
Explanation |
toExplanation(StreamFactory factory) |
StreamExpressionParameter |
toExpression(StreamFactory factory) |
getStreamContextclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitevaluateOverContextpublic AnalyzeEvaluator(StreamExpression expression, StreamFactory factory) throws IOException
IOExceptionpublic void setStreamContext(StreamContext context)
setStreamContext in interface StreamEvaluatorsetStreamContext in class SimpleEvaluatorpublic Object evaluate(Tuple tuple) throws IOException
IOExceptionpublic StreamExpressionParameter toExpression(StreamFactory factory) throws IOException
IOExceptionpublic Explanation toExplanation(StreamFactory factory) throws IOException
IOExceptionCopyright © 2000-2017 Apache Software Foundation. All Rights Reserved.