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) |
getStreamContext
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
evaluateOverContext
public AnalyzeEvaluator(StreamExpression expression, StreamFactory factory) throws IOException
IOException
public void setStreamContext(StreamContext context)
setStreamContext
in interface StreamEvaluator
setStreamContext
in class SourceEvaluator
public Object evaluate(Tuple tuple) throws IOException
IOException
public StreamExpressionParameter toExpression(StreamFactory factory) throws IOException
IOException
public Explanation toExplanation(StreamFactory factory) throws IOException
IOException
Copyright © 2000-2019 Apache Software Foundation. All Rights Reserved.