Saisai Shao created SPARK-5315:
----------------------------------
Summary: reduceByWindow returns Scala DStream not JavaDStream
Key: SPARK-5315
URL: https://issues.apache.org/jira/browse/SPARK-5315
Project: Spark
Issue Type: Bug
Components: Streaming
Affects Versions: 1.2.0
Reporter: Saisai Shao
{code}
def reduceByWindow(
reduceFunc: (T, T) => T,
windowDuration: Duration,
slideDuration: Duration
): DStream[T] = {
dstream.reduceByWindow(reduceFunc, windowDuration, slideDuration)
}
{code}
It should return JavaDStream not DStream for java code.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
