code: def stop(self, stopSparkContext=True, stopGraceFully=False):
          
          while self._on_stop_cb:
              cb = self._on_stop_cb.pop()
              log.debug('calling on_stop_cb {}'.format(cb))
              cb()
  
          IOLoop.current().stop()
  
          StreamingContext._activeContext = None
docs: Stop processing streams.
  
          :param stopSparkContext: stop the SparkContext (NOT IMPLEMENTED)
          :param stopGracefully: stop gracefully (NOT IMPLEMENTED)