Does RichFilterFunction work on multiple thread?

[luutuan]

Hi, when I have a set of objects goes through a RichFilterFunction, by default, will the filter handle all objects in 1 single thread or will divide the work to multiple threads?
Thank you.

[Kostas Kloudas]

Your objects will be processed by a single thread.

Kostas

> On May 26, 2017, at 4:50 PM, luutuan <[hidden email]> wrote:
>
> Hi, when I have a set of objects goes through a RichFilterFunction, by
> default, will the filter handle all objects in 1 single thread or will
> divide the work to multiple threads?
> Thank you.
>
>
>
> --
> View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Does-RichFilterFunction-work-on-multiple-thread-tp13346.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

[Aljoscha Krettek]

Hi,

To expand a bit on that, each function is only invoked by one Thread concurrently but the function might be serialised and sent to several executors (TaskManagers) for parallel execution. For more information, check out [1] and [2].

Best,

Aljoscha

[1] https://ci.apache.org/projects/flink/flink-docs-release-1.3/concepts/programming-model.html

[2] https://ci.apache.org/projects/flink/flink-docs-release-1.3/concepts/runtime.html

On 26. May 2017, at 17:21, Kostas Kloudas <[hidden email]> wrote:

Your objects will be processed by a single thread.

Kostas

On May 26, 2017, at 4:50 PM, luutuan <[hidden email]> wrote:

Hi, when I have a set of objects goes through a RichFilterFunction, by
default, will the filter handle all objects in 1 single thread or will
divide the work to multiple threads?
Thank you.



--
View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Does-RichFilterFunction-work-on-multiple-thread-tp13346.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.