Skip to content
Advertisement

Tag: inner-join

2 consecutive stream-stream inner joins produce wrong results: what does KStream join between streams really do internally?

The problem setting I have a stream of nodes and a stream of edges that represent consecutive updates of a graph and I want to build patterns composed of nodes and edges using multiple joins in series. Let’s suppose I want to match a pattern like: (node1) –[edge1]–> (node2). My idea is to join the stream of nodes with the

Advertisement