Hi,
In the streaming API, the biggest difference is that if you do not
disable object reuse, records will be duplicated/copied when forwarding
from an operator to the downstream one. If you are sure you work with
immutable objects, I'd highly recommend enabling object reuse.
Best,
Dawid
On 08/05/2021 05:24, 杨力 wrote:
> I wrote a streaming job with scala, using only immutable case class.
> Is it safe to enable object reuse? Will it get benefits from enabling
> object reuse?
>
> I reached to documents but they cover neither streaming cases nor
> immutable data structures.