Hi all,
I have question about the differences between WindowedStream and
AllWindowedStream. From the definition I see that WindowedStream are
partitioned based on key but for AllWindowedStream this is not the case.
So, what comes to my mind is, why WindowedStream is not the special case of
Hi all,
I am new to flink. I wrote a simple program and I want it to output as csv
file.
timeWindowAll(Time.of(3, TimeUnit.MINUTES))
.apply(newFunction1())
.writeAsCsv("file:///user/someuser/Documents/somefile.csv");
When I change the sink to . print(), it works and outputs some results.
I
sv does not work by default.
>
> Best,
>
> Marton
>
> On Thu, Feb 4, 2016 at 11:36 AM, Radu Prodan <raduprod...@gmail.com>
> wrote:
>
>> Hi all,
>>
>> I am new to flink. I wrote a simple program and I want it to output as
>> csv file.
>>
>&g
