org.apache.spark.util.logging

Class SizeBasedRollingPolicy

Object

org.apache.spark.util.logging.SizeBasedRollingPolicy

All Implemented Interfaces:

Logging, RollingPolicy

public class SizeBasedRollingPolicy
extends Object
implements RollingPolicy, Logging

Defines a RollingPolicy by which files will be rolled over after reaching a particular size.

Constructor Summary

Constructors

Constructor and Description
SizeBasedRollingPolicy(long rolloverSizeBytes, boolean checkSizeConstraint)

Method Summary

Methods

Modifier and Type	Method and Description
void	bytesWritten(long bytes) Increment the bytes that have been written in the current file
java.text.SimpleDateFormat	formatter()
String	generateRolledOverFileSuffix() Get the desired name of the rollover file
static int	MINIMUM_SIZE_BYTES()
void	rolledOver() Rollover has occurred, so reset the counter
long	rolloverSizeBytes()
boolean	shouldRollover(long bytesToBeWritten) Should rollover if the next set of bytes is going to exceed the size limit

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

SizeBasedRollingPolicy

public SizeBasedRollingPolicy(long rolloverSizeBytes,
                      boolean checkSizeConstraint)

Method Detail

MINIMUM_SIZE_BYTES

public static int MINIMUM_SIZE_BYTES()

rolloverSizeBytes

public long rolloverSizeBytes()

formatter

public java.text.SimpleDateFormat formatter()

shouldRollover

public boolean shouldRollover(long bytesToBeWritten)

Should rollover if the next set of bytes is going to exceed the size limit

Specified by:

shouldRollover in interface RollingPolicy

rolledOver

public void rolledOver()

Rollover has occurred, so reset the counter

Specified by:

rolledOver in interface RollingPolicy

bytesWritten

public void bytesWritten(long bytes)

Increment the bytes that have been written in the current file

Specified by:

bytesWritten in interface RollingPolicy

generateRolledOverFileSuffix

public String generateRolledOverFileSuffix()

Get the desired name of the rollover file

Specified by:

generateRolledOverFileSuffix in interface RollingPolicy