public class EarthMoversEvaluator extends RecursiveEvaluator
| Modifier and Type | Field and Description |
|---|---|
protected static long |
serialVersionUID |
constructingFactory, containedEvaluators, nodeId, streamContext| Constructor and Description |
|---|
EarthMoversEvaluator(StreamExpression expression,
StreamFactory factory) |
EarthMoversEvaluator(StreamExpression expression,
StreamFactory factory,
List<String> ignoredNamedParameters) |
| Modifier and Type | Method and Description |
|---|---|
Object |
doWork(Object... values) |
Object |
evaluate(Tuple tuple) |
getStreamContext, normalizeInputType, normalizeOutputType, recursivelyEvaluate, setStreamContext, toExplanation, toExpressionclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitevaluateOverContextprotected static final long serialVersionUID
public EarthMoversEvaluator(StreamExpression expression, StreamFactory factory) throws IOException
IOExceptionpublic EarthMoversEvaluator(StreamExpression expression, StreamFactory factory, List<String> ignoredNamedParameters) throws IOException
IOExceptionpublic Object evaluate(Tuple tuple) throws IOException
evaluate in interface StreamEvaluatorevaluate in class RecursiveEvaluatorIOExceptionpublic Object doWork(Object... values) throws IOException
IOExceptionCopyright © 2000-2021 Apache Software Foundation. All Rights Reserved.