public abstract class RecursiveEvaluator extends Object implements StreamEvaluator, ValueWorker
| Modifier and Type | Field and Description | 
|---|---|
| protected StreamFactory | constructingFactory | 
| protected List<StreamEvaluator> | containedEvaluators | 
| protected UUID | nodeId | 
| protected static long | serialVersionUID | 
| protected StreamContext | streamContext | 
| Constructor and Description | 
|---|
| RecursiveEvaluator(StreamExpression expression,
                  StreamFactory factory) | 
| RecursiveEvaluator(StreamExpression expression,
                  StreamFactory factory,
                  List<String> ignoredNamedParameters) | 
| Modifier and Type | Method and Description | 
|---|---|
| Object | evaluate(Tuple tuple) | 
| StreamContext | getStreamContext() | 
| protected Object | normalizeInputType(Object value) | 
| protected Object | normalizeOutputType(Object value) | 
| List<Object> | recursivelyEvaluate(Tuple tuple) | 
| void | setStreamContext(StreamContext context) | 
| Explanation | toExplanation(StreamFactory factory)Returns an explanation about the stream object | 
| StreamExpressionParameter | toExpression(StreamFactory factory) | 
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitevaluateOverContextdoWorkprotected static final long serialVersionUID
protected StreamContext streamContext
protected UUID nodeId
protected StreamFactory constructingFactory
protected List<StreamEvaluator> containedEvaluators
public RecursiveEvaluator(StreamExpression expression, StreamFactory factory) throws IOException
IOExceptionpublic RecursiveEvaluator(StreamExpression expression, StreamFactory factory, List<String> ignoredNamedParameters) throws IOException
IOExceptionpublic Object evaluate(Tuple tuple) throws IOException
evaluate in interface StreamEvaluatorIOExceptionpublic List<Object> recursivelyEvaluate(Tuple tuple) throws IOException
IOExceptionpublic StreamExpressionParameter toExpression(StreamFactory factory) throws IOException
toExpression in interface ExpressibleIOExceptionpublic Explanation toExplanation(StreamFactory factory) throws IOException
ExpressibletoExplanation in interface Expressiblefactory - Stream factory for this, contains information about the function nameIOException - throw on any errorpublic void setStreamContext(StreamContext context)
setStreamContext in interface StreamEvaluatorpublic StreamContext getStreamContext()
getStreamContext in interface StreamEvaluatorCopyright © 2000-2019 Apache Software Foundation. All Rights Reserved.