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: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org