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

OpenHashJoin

class OpenHashJoin (source)

Open hash-join to maintain compatibility with concatenating streams instead of evaluating physical plans.

Constructors

<init>

OpenHashJoin(stream1: PathStream, stream2: PathStream, telepath: Telepath = Telepath, materialize: Boolean = true, cardinality: Int = 100, parallel: Boolean = true)

Open hash-join to maintain compatibility with concatenating streams instead of evaluating physical plans.

Functions

evaluate

fun evaluate(): PathStream

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