From 4caae3fdcccabbcd9d1556c43b433b77425eadb9 Mon Sep 17 00:00:00 2001
From: Tathagata Das <tathagata.das1565@gmail.com>
Date: Fri, 1 Aug 2014 14:39:18 -0700
Subject: [PATCH] Added missing file

---
 .../spark/streaming/api/python/PythonRDDFunction.java     | 8 ++++++++
 1 file changed, 8 insertions(+)
 create mode 100644 streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonRDDFunction.java

diff --git a/streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonRDDFunction.java b/streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonRDDFunction.java
new file mode 100644
index 0000000000000..88f7036c3a05b
--- /dev/null
+++ b/streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonRDDFunction.java
@@ -0,0 +1,8 @@
+package org.apache.spark.streaming.api.python;
+
+import org.apache.spark.api.java.JavaRDD;
+import org.apache.spark.streaming.Time;
+
+public interface PythonRDDFunction {
+  JavaRDD<byte[]> call(JavaRDD<byte[]> rdd, long time);
+}