code: def count(self):
          
          return self.mapPartitions(lambda i: [sum(1 for _ in i)]).reduce(operator.add)
docs: Return a new DStream in which each RDD has a single element
          generated by counting each RDD of this DStream.