This project has retired. For details please refer to its Attic page.

org.apache.oozie.util
Class XLogStreamer

java.lang.Object
  org.apache.oozie.util.XLogStreamer

public class XLogStreamer
extends Object

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

Nested Class Summary

static class

XLogStreamer.Filter Filter that will construct the regular expression that will be used to filter the log statement.

Field Summary

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

Constructor Summary

XLogStreamer(XLogStreamer.Filter logFilter, Writer logWriter, String logPath, String logFile, long logRotationSecs)

Method Summary

void	streamLog(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.

Methods inherited from class java.lang.Object

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

Field Detail

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(XLogStreamer.Filter logFilter,
                    Writer logWriter,
                    String logPath,
                    String logFile,
                    long logRotationSecs)

Method Detail

streamLog

public void streamLog(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:

startTime -

endTime -

Throws:

IOException