Hi Alexey," startBundle can be expensive"...Could you elaborate on "expensive"
as per each element pls?
Thanks
From: Demin Alexey <[email protected]>
To: [email protected]
Sent: Friday, November 18, 2016 7:40 AM
Subject: Flink runner. Wrapper for DoFn
Hi
In flink runner we have this code:
https://github.com/apache/incubator-beam/blob/master/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java#L262
but in mostly cases method startBundle can be expensive for making for
every element (for example connection for db/build cache/ etc)
Why so important invoke startBundle/finishBundle on every
incoming streamRecord ?
Thanks
Alexey Diomin
