org.apache.spark.streaming

Class StreamingContextPythonHelper

Object

org.apache.spark.streaming.StreamingContextPythonHelper

public class StreamingContextPythonHelper
extends Object

Constructor Summary

Constructors

Constructor and Description
StreamingContextPythonHelper()

Method Summary

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

Methods inherited from class Object

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

Constructor Detail

StreamingContextPythonHelper

public StreamingContextPythonHelper()

Method Detail

tryRecoverFromCheckpoint

public scala.Option<StreamingContext> tryRecoverFromCheckpoint(String checkpointPath)

This is a private method only for Python to implement getOrCreate.

Parameters:

checkpointPath - (undocumented)

Returns:

(undocumented)