Package org.apache.druid.tasklogs

Class NoopTaskLogs

java.lang.Object

org.apache.druid.tasklogs.NoopTaskLogs

All Implemented Interfaces:

TaskLogKiller, TaskLogPusher, TaskLogs, TaskLogStreamer, TaskPayloadManager

public class NoopTaskLogs
extends Object
implements TaskLogs

Constructor Summary

Constructors

Constructor	Description
NoopTaskLogs()

Method Summary

Modifier and Type	Method	Description
void	killAll()
void	killOlderThan(long timestamp)	Removes logs older than the provided timestamp
void	pushTaskLog(String taskid, File logFile)
void	pushTaskPayload(String taskid, File taskPayloadFile)	Save payload so it can be retrieved later.
void	pushTaskReports(String taskid, File reportFile)
void	pushTaskStatus(String taskid, File statusFile)
com.google.common.base.Optional<InputStream>	streamTaskLog(String taskid, long offset)	Stream log for a task.
com.google.common.base.Optional<InputStream>	streamTaskPayload(String taskid)	Stream payload for a task.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.druid.tasklogs.TaskLogStreamer

streamTaskReports, streamTaskStatus

Constructor Details

NoopTaskLogs

public NoopTaskLogs()

Method Details

streamTaskLog

public com.google.common.base.Optional<InputStream> streamTaskLog(String taskid,
 long offset)

Description copied from interface: TaskLogStreamer

Stream log for a task.

Specified by:

streamTaskLog in interface TaskLogStreamer

offset - If zero, stream the entire log. If positive, attempt to read from this position onwards. If negative, attempt to read this many bytes from the end of the file (like tail -n).

Returns:

inputStream for this log, if available

pushTaskLog

public void pushTaskLog(String taskid,
 File logFile)

Specified by:

pushTaskLog in interface TaskLogPusher

pushTaskReports

public void pushTaskReports(String taskid,
 File reportFile)

Specified by:

pushTaskReports in interface TaskLogPusher

pushTaskStatus

public void pushTaskStatus(String taskid,
 File statusFile)

Specified by:

pushTaskStatus in interface TaskLogPusher

killAll

public void killAll()

Specified by:

killAll in interface TaskLogKiller

killOlderThan

public void killOlderThan(long timestamp)

Description copied from interface: TaskLogKiller

Removes logs older than the provided timestamp

Specified by:

killOlderThan in interface TaskLogKiller

Parameters:

timestamp - Timestamp in milliseconds

pushTaskPayload

public void pushTaskPayload(String taskid,
 File taskPayloadFile)

Description copied from interface: TaskPayloadManager

Save payload so it can be retrieved later.

Specified by:

pushTaskPayload in interface TaskPayloadManager

streamTaskPayload

public com.google.common.base.Optional<InputStream> streamTaskPayload(String taskid)

Description copied from interface: TaskPayloadManager

Stream payload for a task.

Specified by:

streamTaskPayload in interface TaskPayloadManager

Returns:

inputStream for this taskPayload, if available