Re: Re: About the question of Spark Structured Streaming window output

2018-08-27 Thread z...@zjdex.com
the output of agg result of batch 0. But it is not, the batch 2 data does. Thanks! z...@zjdex.com From: Gerard Maas Date: 2018-08-27 17:26 To: zrc CC: kabhwan; spark users; wch Subject: Re: Re: About the question of Spark Structured Streaming window output Hi, > 1、why the start time is &

Re: Re: About the question of Spark Structured Streaming window output

2018-08-26 Thread z...@zjdex.com
not output when the batch1 data is comming? Thanks a lot! z...@zjdex.com From: Jungtaek Lim Date: 2018-08-27 11:01 To: z...@zjdex.com CC: Gerard Maas; user; 王程浩 Subject: Re: Re: About the question of Spark Structured Streaming window output You may want to add streaming listener to your

About the question of Spark Structured Streaming window output

2018-08-22 Thread z...@zjdex.com
ssingTime("10 seconds")) .start() query.awaitTermination() the input data format is : 2018-08-20 12:01:00,1 2018-08-20 12:02:01,1 My questions are: 1、when I set the append output model, I send inputdata, but there is no result to output. How to use append model in window aggreate case