Package | Description |
---|---|
org.apache.oozie | |
org.apache.oozie.service | |
org.apache.oozie.util |
Modifier and Type | Method and Description |
---|---|
protected void |
DagEngine.streamJobLog(XLogStreamer logStreamer,
String jobId,
Writer writer) |
protected void |
CoordinatorEngine.streamJobLog(XLogStreamer logStreamer,
String jobId,
Writer writer) |
protected void |
BundleEngine.streamJobLog(XLogStreamer logStreamer,
String jobId,
Writer writer) |
protected abstract void |
BaseEngine.streamJobLog(XLogStreamer logStreamer,
String jobId,
Writer writer)
Stream job log.
|
Modifier and Type | Method and Description |
---|---|
void |
ZKXLogStreamingService.streamLog(XLogStreamer logStreamer,
Date startTime,
Date endTime,
Writer writer)
Stream the log of a job.
|
void |
XLogStreamingService.streamLog(XLogStreamer logStreamer,
Date startTime,
Date endTime,
Writer writer)
Stream the log of a job.
|
protected void |
XLogStreamingService.streamLog(XLogStreamer logStreamer,
Date startTime,
Date endTime,
Writer writer,
boolean appendDebug)
Stream log.
|
Modifier and Type | Class and Description |
---|---|
class |
XLogAuditStreamer |
class |
XLogErrorStreamer |
Modifier and Type | Method and Description |
---|---|
void |
TimestampedMessageParser.processRemaining(Writer writer,
XLogStreamer logStreamer)
Streams log messages to the passed in Writer, with zero bytes already
written
|
Copyright © 2018 Apache Software Foundation. All rights reserved.