io.druid.tasklogs

Interface TaskLogStreamer

All Known Subinterfaces:

TaskLogs

All Known Implementing Classes:

AzureTaskLogs, FileTaskLogs, ForkingTaskRunner, GoogleTaskLogs, HdfsTaskLogs, NoopTaskLogs, RemoteTaskRunner, S3TaskLogs, SwitchingTaskLogStreamer, TaskRunnerTaskLogStreamer

public interface TaskLogStreamer

Something that knows how to stream logs for tasks.

Method Summary

Modifier and Type	Method and Description
com.google.common.base.Optional<com.google.common.io.ByteSource>	streamTaskLog(String taskid, long offset) Stream log for a task.

Method Detail

streamTaskLog

com.google.common.base.Optional<com.google.common.io.ByteSource> streamTaskLog(String taskid,
                                                                               long offset)
                                                                        throws IOException

Stream log for a task.

Parameters:

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:

input supplier for this log, if available from this provider

Throws:

IOException