File tree Expand file tree Collapse file tree 2 files changed +2
-2
lines changed
src/main/scala/org/apache/spark/streaming/api/python Expand file tree Collapse file tree 2 files changed +2
-2
lines changed Original file line number Diff line number Diff line change 7979 </plugin >
8080
8181 <!--
82- This plugin forces the generation of jar containing streaming test classes,
82+ This plugin forces the generation of jar containing streaming test classes,
8383 so that the tests classes of external modules can use them. The two execution profiles
8484 are necessary - first one for 'mvn package', second one for 'mvn test-compile'. Ideally,
8585 'mvn compile' should not compile test classes and therefore should not need this.
Original file line number Diff line number Diff line change 55
66/*
77 * Interface for py4j callback function.
8- * This function is called by pyspark.streaming.dstream.DStream.foreachRDD .
8+ * This interface is related to pyspark.streaming.dstream.DStream.foreachRDD .
99 */
1010public interface PythonRDDFunction {
1111 JavaRDD <byte []> call (JavaRDD <byte []> rdd , long time );
You can’t perform that action at this time.
0 commit comments