telepath / com.github.giedomak.telepath.physicaloperators / OpenHashJoin / evaluate

evaluate

fun evaluate(): PathStream (source)

Join two streams of Paths following the HashJoin algorithm and by using our SimpleMemoryManager.

Parameters

stream1 - First stream of paths we'll join on its lastNode().

stream2 - Second stream of paths we'll join on its firstNode().

Return
A stream with the concatenated paths of stream1 and stream2.