"/" is integer division, so "x / y * y" is not x, but more like the
biggest multiple of y that's <= x.
On Wed, Oct 17, 2018 at 11:25 AM Sandeep Katta
<sandeep0102.opensou...@gmail.com> wrote:
>
> 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
---------------------------------------------------------------------
To unsubscribe e-mail: dev-unsubscr...@spark.apache.org
