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, wait
evaluateOverContext
doWork
protected 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
IOException
public RecursiveEvaluator(StreamExpression expression, StreamFactory factory, List<String> ignoredNamedParameters) throws IOException
IOException
public Object evaluate(Tuple tuple) throws IOException
evaluate
in interface StreamEvaluator
IOException
public List<Object> recursivelyEvaluate(Tuple tuple) throws IOException
IOException
public StreamExpressionParameter toExpression(StreamFactory factory) throws IOException
toExpression
in interface Expressible
IOException
public Explanation toExplanation(StreamFactory factory) throws IOException
Expressible
toExplanation
in interface Expressible
factory
- Stream factory for this, contains information about the function nameIOException
- throw on any errorpublic void setStreamContext(StreamContext context)
setStreamContext
in interface StreamEvaluator
public StreamContext getStreamContext()
getStreamContext
in interface StreamEvaluator
Copyright © 2000-2017 Apache Software Foundation. All Rights Reserved.