2015 2:04 PM
> *To:* user@spark.apache.org
> *Subject:* Streaming with Java: Expected ReduceByWindow to Return
> JavaDStream
>
>
>
>
>
> Can anyone tell me if my expectations are sane?
>
>
>
> I'm trying to do a reduceByWindow using the 3-arg signature (not prov
t: Monday, January 19, 2015 2:04 PM
To: user@spark.apache.org
Subject: Streaming with Java: Expected ReduceByWindow to Return JavaDStream
Can anyone tell me if my expectations are sane?
I'm trying to do a reduceByWindow using the 3-arg signature (not providing an
inverse reduce function)
Can anyone tell me if my expectations are sane?
I'm trying to do a reduceByWindow using the 3-arg signature (not providing
an inverse reduce function):
JavaDStream reducedStream = messages.reduceByWindow((x, y) ->
reduce(x, y), Durations.seconds(5), Durations.seconds(5));
This isn't building; lo
