org.apache.spark.streaming

Class StreamingContextPythonHelper

java.lang.Object

org.apache.spark.streaming.StreamingContextPythonHelper

public class StreamingContextPythonHelper
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
StreamingContextPythonHelper()

Method Summary

Methods

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

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamingContextPythonHelper

public StreamingContextPythonHelper()

Method Detail

tryRecoverFromCheckpoint

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

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

Parameters:

checkpointPath - (undocumented)

Returns:

(undocumented)