Hi.

I am in the process of migrating from DStreams to structured steaming. In
DStream API job we were using batch size as 1 minute and it was taking
30-45 secs to process it.

With structured streaming I am using a trigger interval of 30 secs but it
seems to be taking a large amount of time to process

Will setting maxOffsetsPerTrigger help me? How does that map to the
previous DStream batch size ?

Thanks
Girish
-- 
Thanks & Regards,
Girish Subramanian

Reply via email to