Package org.apache.spark.streaming

Class StreamingContextPythonHelper

Object

org.apache.spark.streaming.StreamingContextPythonHelper

public class StreamingContextPythonHelper
extends Object

Constructor Summary

Constructors

Constructor	Description
StreamingContextPythonHelper()

Method Summary

Modifier and Type	Method	Description
scala.Option<StreamingContext>	tryRecoverFromCheckpoint(String checkpointPath)	This is a private method only for Python to implement getOrCreate.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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)