public class NoopTaskLogs extends Object implements TaskLogs
Constructor and Description |
---|
NoopTaskLogs() |
Modifier and Type | Method and Description |
---|---|
void |
killAll() |
void |
killOlderThan(long timestamp) |
void |
pushTaskLog(String taskid,
File logFile) |
com.google.common.base.Optional<com.google.common.io.ByteSource> |
streamTaskLog(String taskid,
long offset)
Stream log for a task.
|
public com.google.common.base.Optional<com.google.common.io.ByteSource> streamTaskLog(String taskid, long offset) throws IOException
TaskLogStreamer
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).IOException
public void pushTaskLog(String taskid, File logFile) throws IOException
pushTaskLog
in interface TaskLogPusher
IOException
public void killAll() throws IOException
killAll
in interface TaskLogKiller
IOException
public void killOlderThan(long timestamp) throws IOException
killOlderThan
in interface TaskLogKiller
IOException
Copyright © 2011–2017. All rights reserved.