Skip to content

Commit 4caae3f

Browse files
tdasgiwa
authored andcommitted
Added missing file
1 parent 4eff053 commit 4caae3f

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,8 @@
1+
package org.apache.spark.streaming.api.python;
2+
3+
import org.apache.spark.api.java.JavaRDD;
4+
import org.apache.spark.streaming.Time;
5+
6+
public interface PythonRDDFunction {
7+
JavaRDD<byte[]> call(JavaRDD<byte[]> rdd, long time);
8+
}

0 commit comments

Comments
 (0)