class_docstr: Main entry point for Spark Streaming functionality. A StreamingContext
  represents the connection to a Spark cluster, and can be used to create
  :class:`DStream` various input sources. It can be from an existing :class:`SparkContext`.
  After creating and transforming DStreams, the streaming computation can
  be started and stopped using `context.start()` and `context.stop()`,
  respectively. `context.awaitTermination()` allows the current thread
  to wait for the termination of the context by `stop()` or by an exception.
  
  .. deprecated:: Spark 3.4.0
     This is deprecated as of Spark 3.4.0.
     There are no longer updates to DStream and it's a legacy project.
     There is a newer and easier to use streaming engine in Spark called Structured Streaming.
     You should use Spark Structured Streaming for your streaming applications.
  
  Parameters
  ----------
  sparkContext : :class:`SparkContext`
      SparkContext object.
  batchDuration : int, optional
      the time interval (in seconds) at which streaming
      data will be divided into batches
class_docstr_tok: ["Main","entry","point","for","Spark","Streaming","functionality",".","A","StreamingContext","represents","the","connection","to","a","Spark","cluster",",","and","can","be","used","to","create",":","class",":","`","DStream","`","various","input","sources",".","It","can","be","from","an","existing",":","class",":","`","SparkContext","`",".","After","creating","and","transforming","DStreams",",","the","streaming","computation","can","be","started","and","stopped","using","`","context.start","(",")","`","and","`","context.stop","(",")","`",",","respectively",".","`","context.awaitTermination","(",")","`","allows","the","current","thread","to","wait","for","the","termination","of","the","context","by","`","stop","(",")","`","or","by","an","exception",".","..","deprecated",":",":","Spark","3.4.0","This","is","deprecated","as","of","Spark","3.4.0",".","There","are","no","longer","updates","to","DStream","and","it","'s","a","legacy","project",".","There","is","a","newer","and","easier","to","use","streaming","engine","in","Spark","called","Structured","Streaming",".","You","should","use","Spark","Structured","Streaming","for","your","streaming","applications",".","Parameters","--","--","--","--","--","sparkContext",":",":","class",":","`","SparkContext","`","SparkContext","object",".","batchDuration",":","int",",","optional","the","time","interval","(","in","seconds",")","at","which","streaming","data","will","be","divided","into","batches"]
docstr: Set each DStreams in this context to remember RDDs it generated
  in the last given duration. DStreams remember RDDs only for a
  limited duration of time and releases them for garbage collection.
  This method allows the developer to specify how long to remember
  the RDDs (if the developer wishes to query old data outside the
  DStream computation).
  
  Parameters
  ----------
  duration : int
      Minimum duration (in seconds) that each DStream should remember its RDDs
docstr_tok: ["Set","each","DStreams","in","this","context","to","remember","RDDs","it","generated","in","the","last","given","duration",".","DStreams","remember","RDDs","only","for","a","limited","duration","of","time","and","releases","them","for","garbage","collection",".","This","method","allows","the","developer","to","specify","how","long","to","remember","the","RDDs","(","if","the","developer","wishes","to","query","old","data","outside","the","DStream","computation",")",".","Parameters","--","--","--","--","--","duration",":","int","Minimum","duration","(","in","seconds",")","that","each","DStream","should","remember","its","RDDs"]
code: def remember(self, duration: int) -> None:
      """
      Set each DStreams in this context to remember RDDs it generated
      in the last given duration. DStreams remember RDDs only for a
      limited duration of time and releases them for garbage collection.
      This method allows the developer to specify how long to remember
      the RDDs (if the developer wishes to query old data outside the
      DStream computation).
  
      Parameters
      ----------
      duration : int
          Minimum duration (in seconds) that each DStream should remember its RDDs
      """
      self._jssc.remember(self._jduration(duration))
  
imports: from typing import Any, Callable, List, Optional, TypeVar
  from py4j.java_gateway import java_import, is_instance_of, JavaObject
  from pyspark import RDD, SparkConf
  from pyspark.serializers import NoOpSerializer, UTF8Deserializer, CloudPickleSerializer
  from pyspark.context import SparkContext
  from pyspark.storagelevel import StorageLevel
  from pyspark.streaming.dstream import DStream
  from pyspark.streaming.listener import StreamingListener
  from pyspark.streaming.util import TransformFunction, TransformFunctionSerializer
  import warnings
label_desc: Use image node_id 13 for calling the StreamingContext obj's underlying member method code with example usage: obj.remember(duration) without return types