public class ReplayListenerBus extends Object implements SparkListenerBus, Logging
Constructor and Description |
---|
ReplayListenerBus() |
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.
|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onPostEvent
addListener, listeners, postToAll
initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning
public void replay(java.io.InputStream logData, String sourceName)
This method can be called multiple times, but the listener behavior is undefined after any error is thrown by this method.
logData
- Stream containing event log data.sourceName
- Filename (or other source identifier) from whence @logData is being read