Hi Dmitry,
the runtime supports an arbitrary number of inputs, however, the API
does currently not provide a convenient way. You could use the "union"
operator to reduce the number of inputs. Otherwise I think you have to
implement your own operator. That depends on your use case though.
You can maintain backpressure by using Flink's operator state. But did
you also thought about a Window Join instead?
I hope that helps.
Timo
Am 17/01/17 um 00:20 schrieb Dmitry Golubets:
Hi,
there are only *two *interfaces defined at the moment:
/OneInputStreamOperator/
and
/TwoInputStreamOperator./
Is there any way to define an operator with arbitrary number of inputs?
My another concern is how to maintain *backpressure *in the operator?
Let's say I read events from two Kafka sources, both of which are
ordered by time. I want to merge them keeping the global order. But to
do it, I need to stop block one input if another one has no data yet.
Best regards,
Dmitry
