org.apache.oozie.service

Class XLogStreamingService

java.lang.Object

org.apache.oozie.service.XLogStreamingService

All Implemented Interfaces:

Service, Instrumentable

Direct Known Subclasses:

ZKXLogStreamingService

public class XLogStreamingService
extends Object
implements Service, Instrumentable

Service that performs streaming of log files over Web Services if enabled in XLogService

Field Summary

Fields inherited from interface org.apache.oozie.service.Service

CONF_PREFIX, DEFAULT_LOCK_TIMEOUT, lockTimeout

Constructor Summary

Constructors

Constructor and Description
XLogStreamingService()

Method Summary

Modifier and Type	Method and Description
void	destroy() Destroy the log streaming service.
Class<? extends Service>	getInterface() Return the public interface for log streaming service.
void	init(Services services) Initialize the log streaming service.
void	instrument(Instrumentation instr) Instruments the log streaming service.
void	streamLog(XLogStreamer logStreamer, Date startTime, Date endTime, Writer writer) Stream the log of a job.
protected void	streamLog(XLogStreamer logStreamer, Date startTime, Date endTime, Writer writer, boolean appendDebug) Stream log.

Methods inherited from class java.lang.Object

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

Constructor Detail

XLogStreamingService

public XLogStreamingService()

Method Detail

init

public void init(Services services)
          throws ServiceException

Initialize the log streaming service.

Specified by:

init in interface Service

Parameters:

services - services instance.

Throws:

ServiceException - thrown if the log streaming service could not be initialized.

destroy

public void destroy()

Destroy the log streaming service.

Specified by:

destroy in interface Service

getInterface

public Class<? extends Service> getInterface()

Return the public interface for log streaming service.

Specified by:

getInterface in interface Service

Returns:

XLogStreamingService.

instrument

public void instrument(Instrumentation instr)

Instruments the log streaming service.

Specified by:

instrument in interface Instrumentable

Parameters:

instr - instrumentation to use.

streamLog

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

Stream the log of a job.

Parameters:

logStreamer - the log streamer

startTime - start time for log events to filter.

endTime - end time for log events to filter.

writer - writer to stream the log to.

Throws:

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

streamLog

protected void streamLog(XLogStreamer logStreamer,
                         Date startTime,
                         Date endTime,
                         Writer writer,
                         boolean appendDebug)
                  throws IOException

Stream log.

Parameters:

logStreamer - the log streamer

startTime - the start time

endTime - the end time

writer - the writer

appendDebug - the append debug

Throws:

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