Hello Govindarajan,
one way to merge multiple streams is to union them. You can do that with
the union operator described at [1]. Is that what you are looking for?
[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/datastream_api.html
-- Jonas
Am Mo, 24. Jul 2017, um 23:18,
Hello Jeremy,
it looks like what you are looking for is map (1 in, 1 out) / flatmap (1 in,
0-n out) for preprocessing on a single element basis as well as windows for
looking at related MetricDefinition elements calculating some result.
I suggest you look into Windows
Hi nragon,
apparently I didn't read the P.S. since I assumed its not important. Silly
me.
So you are trying to join stream A and B to stream C with stream A and B
being keyed. Alright. Are how often do matching elements (matched by primary
key) from A and B arrive on your operator
Hey nragon!
Do the two streams A and B have some sort of id or key or how do you plan on
joining them?
Do you just want to join A and B with elements a and b as they arrive (one
in state and join with the next arriving one from the other stream)?
>From what you are asking, this should be no
