public class FileAppender extends Object implements Logging
Constructor and Description |
---|
FileAppender(java.io.InputStream inputStream,
java.io.File file,
int bufferSize) |
Modifier and Type | Method and Description |
---|---|
static FileAppender |
apply(java.io.InputStream inputStream,
java.io.File file,
SparkConf conf)
Create the right appender based on Spark configuration
|
void |
awaitTermination()
Wait for the appender to stop appending, either because input stream is closed
or because of any error in appending
|
void |
stop()
Stop the appender
|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning
public FileAppender(java.io.InputStream inputStream, java.io.File file, int bufferSize)
public static FileAppender apply(java.io.InputStream inputStream, java.io.File file, SparkConf conf)
public void awaitTermination()
public void stop()