org.apache.oozie.util

Class XLogStreamer

java.lang.Object

org.apache.oozie.util.XLogStreamer

Direct Known Subclasses:

XLogAuditStreamer, XLogErrorStreamer

public class XLogStreamer
extends Object

XLogStreamer streams the given log file to writer after applying the given filter.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	XLogStreamer.FileInfo File along with the modified time which will be used to sort later.

Field Summary

Fields

Modifier and Type	Field and Description
protected int	bufferLen
protected static String	CONF_PREFIX
static Pattern	gzTimePattern This pattern matches the end of a gzip filename to have a format like "-YYYY-MM-dd-HH.gz" with capturing groups for each part of the date
protected XLogFilter	logFilter
static String	STREAM_BUFFER_LEN
protected int	totalDataWritten

Constructor Summary

Constructors

Constructor and Description
XLogStreamer(Map<String,String[]> params)
XLogStreamer(XLogFilter logFilter)
XLogStreamer(XLogFilter logFilter, Map<String,String[]> params)
XLogStreamer(XLogFilter logFilter, String logPath, String logFile, long logRotationSecs)

Method Summary

Modifier and Type	Method and Description
protected void	calculateAndValidateDateRange(Date startTime, Date endTime)
int	getBufferLen()
String	getLogDisableMessage()
String	getLogType()
Map<String,String[]>	getRequestParam()
XLogFilter	getXLogFilter()
boolean	isLogEnabled()
BufferedReader	makeReader(Date startTime, Date endTime)
boolean	shouldFlushOutput(int writtenBytes)
void	streamLog(Writer writer, Date startTime, Date endTime) Gets the files that are modified between startTime and endTime in the given logPath and streams the log after applying the filters.
void	streamLog(Writer writer, Date startTime, Date endTime, boolean appendDebug) Gets the files that are modified between startTime and endTime in the given logPath and streams the log after applying the filters

Methods inherited from class java.lang.Object

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

Field Detail

CONF_PREFIX

protected static final String CONF_PREFIX

See Also:

Constant Field Values

STREAM_BUFFER_LEN

public static final String STREAM_BUFFER_LEN

See Also:

Constant Field Values

logFilter

protected XLogFilter logFilter

totalDataWritten

protected int totalDataWritten

bufferLen

protected int bufferLen

gzTimePattern

public static final Pattern gzTimePattern

This pattern matches the end of a gzip filename to have a format like "-YYYY-MM-dd-HH.gz" with capturing groups for each part of the date

Constructor Detail

XLogStreamer

public XLogStreamer(XLogFilter logFilter,
                    String logPath,
                    String logFile,
                    long logRotationSecs)

XLogStreamer

public XLogStreamer(XLogFilter logFilter)

XLogStreamer

public XLogStreamer(XLogFilter logFilter,
                    Map<String,String[]> params)

XLogStreamer

public XLogStreamer(Map<String,String[]> params)
             throws CommandException

Throws:

CommandException

Method Detail

streamLog

public void streamLog(Writer writer,
                      Date startTime,
                      Date endTime)
               throws IOException

Gets the files that are modified between startTime and endTime in the given logPath and streams the log after applying the filters.

Parameters:

writer - the target writer

startTime - the start time

endTime - the end time

Throws:

IOException - Signals that an I/O exception has occurred.

streamLog

public void streamLog(Writer writer,
                      Date startTime,
                      Date endTime,
                      boolean appendDebug)
               throws IOException

Gets the files that are modified between startTime and endTime in the given logPath and streams the log after applying the filters

Parameters:

writer - the writer

startTime - the start time

endTime - the end time

appendDebug - the append debug

Throws:

IOException - Signals that an I/O exception has occurred.

calculateAndValidateDateRange

protected void calculateAndValidateDateRange(Date startTime,
                                             Date endTime)
                                      throws IOException

Throws:

IOException

makeReader

public BufferedReader makeReader(Date startTime,
                                 Date endTime)
                          throws IOException

Throws:

IOException

isLogEnabled

public boolean isLogEnabled()

getLogType

public String getLogType()

getXLogFilter

public XLogFilter getXLogFilter()

getLogDisableMessage

public String getLogDisableMessage()

getRequestParam

public Map<String,String[]> getRequestParam()

shouldFlushOutput

public boolean shouldFlushOutput(int writtenBytes)

getBufferLen

public int getBufferLen()