THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
In KStreamImpl
, implementation is fairly simple:
- We call
op
, passing our currentKStream
as its argument. This produces ouroutput
KStream.
- We determine if repartitioning is required on the
op
stream, and if it is, we automatically include a repartition node, equivalent to adding.repartition()
to the end of theop
stream.We callop
, passing our currentKStream
as its argument. This produces ouroutput
KStream. - We wire up the
graphNode
from theoutput
KStream
as a parent of the currentKStream
. This takes care of the recursion. - Finally, we return the
output
KStream
. This enables users to operate on the records that are being recursively produced, as above.
...