org.apache.spark.util.logging

Class RollingFileAppender

Object

org.apache.spark.util.logging.FileAppender

org.apache.spark.util.logging.RollingFileAppender

All Implemented Interfaces:

Logging

public class RollingFileAppender
extends FileAppender

Continuously appends data from input stream into the given file, and rolls over the file after the given interval. The rolled over files are named based on the given pattern.

Constructor Summary

Constructors

Constructor and Description
RollingFileAppender(java.io.InputStream inputStream, java.io.File activeFile, RollingPolicy rollingPolicy, SparkConf conf, int bufferSize)

Method Summary

Methods

Modifier and Type	Method and Description
static int	DEFAULT_BUFFER_SIZE()
void	deleteOldFiles() Retain only last few files
static scala.collection.Seq<java.io.File>	getSortedRolledOverFiles(String directory, String activeFileName) Get the sorted list of rolled over files.
static String	INTERVAL_DEFAULT()
static String	INTERVAL_PROPERTY()
static String	RETAINED_FILES_PROPERTY()
RollingPolicy	rollingPolicy()
static String	SIZE_DEFAULT()
static String	SIZE_PROPERTY()
void	stop() Stop the appender
static String	STRATEGY_DEFAULT()
static String	STRATEGY_PROPERTY()

Methods inherited from class org.apache.spark.util.logging.FileAppender

apply, awaitTermination

Methods inherited from class Object

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

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

RollingFileAppender

public RollingFileAppender(java.io.InputStream inputStream,
                   java.io.File activeFile,
                   RollingPolicy rollingPolicy,
                   SparkConf conf,
                   int bufferSize)

Method Detail

STRATEGY_PROPERTY

public static String STRATEGY_PROPERTY()

STRATEGY_DEFAULT

public static String STRATEGY_DEFAULT()

INTERVAL_PROPERTY

public static String INTERVAL_PROPERTY()

INTERVAL_DEFAULT

public static String INTERVAL_DEFAULT()

SIZE_PROPERTY

public static String SIZE_PROPERTY()

SIZE_DEFAULT

public static String SIZE_DEFAULT()

RETAINED_FILES_PROPERTY

public static String RETAINED_FILES_PROPERTY()

DEFAULT_BUFFER_SIZE

public static int DEFAULT_BUFFER_SIZE()

getSortedRolledOverFiles

public static scala.collection.Seq<java.io.File> getSortedRolledOverFiles(String directory,
                                                          String activeFileName)

Get the sorted list of rolled over files. This assumes that the all the rolled over file names are prefixed with the activeFileName, and the active file name has the latest logs. So it sorts all the rolled over logs (that are prefixed with activeFileName) and appends the active file

rollingPolicy

public RollingPolicy rollingPolicy()

stop

public void stop()

Stop the appender

Overrides:

stop in class FileAppender

deleteOldFiles

public void deleteOldFiles()

Retain only last few files