org.apache.spark.util.logging

Class TimeBasedRollingPolicy

Object

org.apache.spark.util.logging.TimeBasedRollingPolicy

All Implemented Interfaces:

Logging, RollingPolicy

public class TimeBasedRollingPolicy
extends Object
implements RollingPolicy, Logging

Defines a RollingPolicy by which files will be rolled over at a fixed interval.

Constructor Summary

Constructors

Constructor and Description
TimeBasedRollingPolicy(long rolloverIntervalMillis, String rollingFileSuffixPattern, boolean checkIntervalConstraint)

Method Summary

Methods

Modifier and Type	Method and Description
void	bytesWritten(long bytes) Notify that bytes have been written
String	generateRolledOverFileSuffix() Get the desired name of the rollover file
static long	MINIMUM_INTERVAL_SECONDS()
void	rolledOver() Rollover has occurred, so find the next time to rollover
long	rolloverIntervalMillis()
boolean	shouldRollover(long bytesToBeWritten) Should rollover if current time has exceeded next rollover time

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

TimeBasedRollingPolicy

public TimeBasedRollingPolicy(long rolloverIntervalMillis,
                      String rollingFileSuffixPattern,
                      boolean checkIntervalConstraint)

Method Detail

MINIMUM_INTERVAL_SECONDS

public static long MINIMUM_INTERVAL_SECONDS()

rolloverIntervalMillis

public long rolloverIntervalMillis()

shouldRollover

public boolean shouldRollover(long bytesToBeWritten)

Should rollover if current time has exceeded next rollover time

Specified by:

shouldRollover in interface RollingPolicy

rolledOver

public void rolledOver()

Rollover has occurred, so find the next time to rollover

Specified by:

rolledOver in interface RollingPolicy

bytesWritten

public void bytesWritten(long bytes)

Description copied from interface: RollingPolicy

Notify that bytes have been written

Specified by:

bytesWritten in interface RollingPolicy

generateRolledOverFileSuffix

public String generateRolledOverFileSuffix()

Description copied from interface: RollingPolicy

Get the desired name of the rollover file

Specified by:

generateRolledOverFileSuffix in interface RollingPolicy