Class CheckpointReader

Object
org.apache.spark.streaming.CheckpointReader

public class CheckpointReader extends Object
  • Constructor Details

    • CheckpointReader

      public CheckpointReader()
  • Method Details

    • read

      public static scala.Option<org.apache.spark.streaming.Checkpoint> read(String checkpointDir)
      Read checkpoint files present in the given checkpoint directory. If there are no checkpoint files, then return None, else try to return the latest valid checkpoint object. If no checkpoint files could be read correctly, then return None.
      Parameters:
      checkpointDir - (undocumented)
      Returns:
      (undocumented)
    • read

      public static scala.Option<org.apache.spark.streaming.Checkpoint> read(String checkpointDir, SparkConf conf, org.apache.hadoop.conf.Configuration hadoopConf, boolean ignoreReadError)
      Read checkpoint files present in the given checkpoint directory. If there are no checkpoint files, then return None, else try to return the latest valid checkpoint object. If no checkpoint files could be read correctly, then return None (if ignoreReadError = true), or throw exception (if ignoreReadError = false).
      Parameters:
      checkpointDir - (undocumented)
      conf - (undocumented)
      hadoopConf - (undocumented)
      ignoreReadError - (undocumented)
      Returns:
      (undocumented)
    • org$apache$spark$internal$Logging$$log_

      public static org.slf4j.Logger org$apache$spark$internal$Logging$$log_()
    • org$apache$spark$internal$Logging$$log__$eq

      public static void org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)