diff --git a/python/pyspark/streaming/dstream.py b/python/pyspark/streaming/dstream.py index 3365c6d69c1a2..3df6e5e09b0c1 100644 --- a/python/pyspark/streaming/dstream.py +++ b/python/pyspark/streaming/dstream.py @@ -55,50 +55,6 @@ def pyprint(self): """ self._jdstream.pyprint() - def cache(self): - """ - """ - raise NotImplementedError - - def checkpoint(self): - """ - """ - raise NotImplementedError - - def compute(self, time): - """ - """ - raise NotImplementedError - - def context(self): - """ - """ - raise NotImplementedError - - def count(self): - """ - """ - raise NotImplementedError - - def countByValue(self, numPartitions=None): - """ - """ - raise NotImplementedError - - def countByValueAndWindow(self, duration, slideDuration=None): - """ - """ - raise NotImplementedError - - def countByWindow(self, duration, slideDuration=None): - """ - """ - raise NotImplementedError - - def dstream(self): - """ - """ - raise NotImplementedError def filter(self, f): """ @@ -112,16 +68,6 @@ def flatMap(self, f, preservesPartitioning=False): def func(s, iterator): return chain.from_iterable(imap(f, iterator)) return self.mapPartitionsWithIndex(func, preservesPartitioning) - def foreachRDD(self, f, time): - """ - """ - raise NotImplementedError - - def glom(self): - """ - """ - raise NotImplementedError - def map(self, f, preservesPartitioning=False): """ """ @@ -134,11 +80,6 @@ def mapPartitions(self, f): def func(s, iterator): return f(iterator) return self.mapPartitionsWithIndex(func) - def perist(self, storageLevel): - """ - """ - raise NotImplementedError - def reduce(self, func, numPartitions=None): """ @@ -210,49 +151,6 @@ def add_shuffle_key(split, iterator): dstream._partitionFunc = partitionFunc return dstream - - def reduceByWindow(self, reduceFunc, windowDuration, slideDuration, inReduceTunc): - """ - """ - - raise NotImplementedError - - def repartition(self, numPartitions): - """ - """ - raise NotImplementedError - - def slice(self, fromTime, toTime): - """ - """ - raise NotImplementedError - - def transform(self, transformFunc): - """ - """ - self._jdstream.transform(transformFunc) - raise NotImplementedError - - def transformWith(self, other, transformFunc): - """ - """ - raise NotImplementedError - - def union(self, that): - """ - """ - raise NotImplementedError - - def window(self, windowDuration, slideDuration=None): - """ - """ - raise NotImplementedError - - def wrapRDD(self, rdd): - """ - """ - raise NotImplementedError - def mapPartitionsWithIndex(self, f, preservesPartitioning=False): """