org.apache.spark.scheduler

Class ReplayListenerBus

Object

org.apache.spark.scheduler.ReplayListenerBus

All Implemented Interfaces:

Logging, SparkListenerBus, ListenerBus<SparkListener,SparkListenerEvent>

public class ReplayListenerBus
extends Object
implements SparkListenerBus, Logging

A SparkListenerBus that can be used to replay events from serialized event data.

Constructor Summary

Constructors

Constructor and Description
ReplayListenerBus()

Method Summary

Methods

Modifier and Type	Method and Description
void	replay(java.io.InputStream logData, String sourceName) Replay each event in the order maintained in the given stream.

Methods inherited from class Object

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

Methods inherited from interface org.apache.spark.scheduler.SparkListenerBus

onPostEvent

Methods inherited from interface org.apache.spark.util.ListenerBus

addListener, listeners, postToAll

Methods inherited from interface org.apache.spark.Logging

initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Constructor Detail

ReplayListenerBus

public ReplayListenerBus()

Method Detail

replay

public void replay(java.io.InputStream logData,
          String sourceName)

Replay each event in the order maintained in the given stream. The stream is expected to contain one JSON-encoded SparkListenerEvent per line.

This method can be called multiple times, but the listener behavior is undefined after any error is thrown by this method.

Parameters:

logData - Stream containing event log data.

sourceName - Filename (or other source identifier) from whence @logData is being read