Interface StreamEvaluator

    • Method Detail

      • setStreamContext

        void setStreamContext​(StreamContext streamContext)
      • evaluateOverContext

        default Object evaluateOverContext()
                                    throws IOException
        Execute the evaluator over lets stored within the StreamContext. This allows evaluators to be executed over values calculated elsewhere in the pipeline and stored in the streamContext.lets

        Default implementation just creates a tuple out of all values in the context and passes that to evaluate(Tuple).

        Returns:
        Evaluated value
        Throws:
        IOException - throw on error during evaluation