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 w
> Best,
>
> Marton
>
> On Thu, Feb 4, 2016 at 11:36 AM, Radu Prodan
> wrote:
>
>> 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))
>&g
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
AllWin
