public class CorrelationEvaluator extends RecursiveObjectEvaluator implements ManyValueWorker
Modifier and Type | Class and Description |
---|---|
static class |
CorrelationEvaluator.CorrelationType |
Modifier and Type | Field and Description |
---|---|
protected static long |
serialVersionUID |
constructingFactory, containedEvaluators, nodeId, streamContext
Constructor and Description |
---|
CorrelationEvaluator(StreamExpression expression,
StreamFactory factory) |
Modifier and Type | Method and Description |
---|---|
Object |
doWork(Object... values) |
evaluate, getStreamContext, normalizeInputType, normalizeOutputType, recursivelyEvaluate, setStreamContext, toExplanation, toExpression
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
evaluateOverContext
protected static final long serialVersionUID
public CorrelationEvaluator(StreamExpression expression, StreamFactory factory) throws IOException
IOException
public Object doWork(Object... values) throws IOException
doWork
in interface ManyValueWorker
doWork
in interface ValueWorker
IOException
Copyright © 2000-2018 Apache Software Foundation. All Rights Reserved.