public class AnalyzeEvaluator extends SourceEvaluator
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 SourceEvaluatorpublic 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.