Class StreamingContextPythonHelper

Object
org.apache.spark.streaming.StreamingContextPythonHelper

public class StreamingContextPythonHelper extends Object
  • Constructor Details

    • StreamingContextPythonHelper

      public StreamingContextPythonHelper()
  • Method Details

    • tryRecoverFromCheckpoint

      public scala.Option<StreamingContext> tryRecoverFromCheckpoint(String checkpointPath)
      This is a private method only for Python to implement getOrCreate.
      Parameters:
      checkpointPath - (undocumented)
      Returns:
      (undocumented)