We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 05e991b commit 9ab8952Copy full SHA for 9ab8952
python/pyspark/streaming/utils.py
@@ -17,6 +17,7 @@
17
18
from pyspark.rdd import RDD
19
20
+
21
class RDDFunction():
22
def __init__(self, ctx, jrdd_deserializer, func):
23
self.ctx = ctx
0 commit comments