We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 4caae3f commit c9fc124Copy full SHA for c9fc124
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