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 79
79
</plugin >
80
80
81
81
<!--
82
- This plugin forces the generation of jar containing streaming test classes,
82
+ This plugin forces the generation of jar containing streaming test classes,
83
83
so that the tests classes of external modules can use them. The two execution profiles
84
84
are necessary - first one for 'mvn package', second one for 'mvn test-compile'. Ideally,
85
85
'mvn compile' should not compile test classes and therefore should not need this.
Original file line number Diff line number Diff line change 5
5
6
6
/*
7
7
* 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 .
9
9
*/
10
10
public interface PythonRDDFunction {
11
11
JavaRDD <byte []> call (JavaRDD <byte []> rdd , long time );
You can’t perform that action at this time.
0 commit comments