Class JoinNode

  • All Implemented Interfaces:
    Node

    public class JoinNode
    extends java.lang.Object
    implements Node
    Interpreter node that implements a Join.
    • Field Detail

      • leftSource

        private final Source leftSource
      • rightSource

        private final Source rightSource
      • sink

        private final Sink sink
      • rel

        private final Join rel
      • condition

        private final Scalar condition
      • context

        private final Context context
    • Constructor Detail

      • JoinNode

        public JoinNode​(Compiler compiler,
                        Join rel)
    • Method Detail

      • run

        public void run()
                 throws java.lang.InterruptedException
        Specified by:
        run in interface Node
        Throws:
        java.lang.InterruptedException