You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@spark.apache.org by naresh Goud <na...@gmail.com> on 2018/02/25 20:26:40 UTC

Trigger.ProcessingTime("10 seconds") & Trigger.Continuous(10.seconds)

Hello Spark Experts,

What is the difference between Trigger.Continuous(10.seconds) and
Trigger.ProcessingTime("10 seconds") ?



Thank you,
Naresh

Re: Trigger.ProcessingTime("10 seconds") & Trigger.Continuous(10.seconds)

Posted by naresh Goud <na...@gmail.com>.

Thanks, I'll check it out.

On Mon, Feb 26, 2018 at 12:11 AM Tathagata Das <ta...@gmail.com>
wrote:

> The continuous one is our new low latency continuous processing engine in
> Structured Streaming (to be released in 2.3).
> Here is the pre-release doc -
> https://dist.apache.org/repos/dist/dev/spark/v2.3.0-rc5-docs/_site/structured-streaming-programming-guide.html#continuous-processing
>
> On Sun, Feb 25, 2018 at 12:26 PM, naresh Goud <na...@gmail.com>
> wrote:
>
>> Hello Spark Experts,
>>
>> What is the difference between Trigger.Continuous(10.seconds) and
>> Trigger.ProcessingTime("10 seconds") ?
>>
>>
>>
>> Thank you,
>> Naresh
>>
>
>

Re: Trigger.ProcessingTime("10 seconds") & Trigger.Continuous(10.seconds)

Posted by Tathagata Das <ta...@gmail.com>.

The continuous one is our new low latency continuous processing engine in
Structured Streaming (to be released in 2.3).
Here is the pre-release doc -
https://dist.apache.org/repos/dist/dev/spark/v2.3.0-rc5-docs/_site/structured-streaming-programming-guide.html#continuous-processing

On Sun, Feb 25, 2018 at 12:26 PM, naresh Goud <na...@gmail.com>
wrote:

> Hello Spark Experts,
>
> What is the difference between Trigger.Continuous(10.seconds) and
> Trigger.ProcessingTime("10 seconds") ?
>
>
>
> Thank you,
> Naresh
>