public class ReplayListenerBus extends Object implements SparkListenerBus, Logging
This assumes the given paths are valid log files, where each line can be deserialized into exactly one SparkListenerEvent.
Constructor and Description |
---|
ReplayListenerBus(scala.collection.Seq<org.apache.hadoop.fs.Path> logPaths,
org.apache.hadoop.fs.FileSystem fileSystem,
scala.Option<CompressionCodec> compressionCodec) |
Modifier and Type | Method and Description |
---|---|
void |
replay()
Replay each event in the order maintained in the given logs.
|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addListener, foreachListener, postToAll, sparkListeners
initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning
public ReplayListenerBus(scala.collection.Seq<org.apache.hadoop.fs.Path> logPaths, org.apache.hadoop.fs.FileSystem fileSystem, scala.Option<CompressionCodec> compressionCodec)