Hi Guys, I am trying to understand structured streaming code flow by doing so I came across below code flow
def nextBatchTime(now: Long): Long = {
if (intervalMs == 0) now else now / intervalMs * intervalMs + intervalMs
}
else part could also have been written as
now + intervalMs
is there any specific reason why that code is written like above,or is
it by mistake ?
Apologies upfront if this is really silly/basic question.
Regards
Sandeep Katta
