io.druid.indexing.common.tasklogs

Class FileTaskLogs

java.lang.Object

io.druid.indexing.common.tasklogs.FileTaskLogs

All Implemented Interfaces:

io.druid.tasklogs.TaskLogPusher, io.druid.tasklogs.TaskLogs, io.druid.tasklogs.TaskLogStreamer

public class FileTaskLogs
extends Object
implements io.druid.tasklogs.TaskLogs

Constructor Summary

Constructors

Constructor and Description
FileTaskLogs(FileTaskLogsConfig config)

Method Summary

Methods

Modifier and Type	Method and Description
void	pushTaskLog(String taskid, File file)
com.google.common.base.Optional<com.google.common.io.InputSupplier<InputStream>>	streamTaskLog(String taskid, long offset)

Methods inherited from class java.lang.Object

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

Constructor Detail

FileTaskLogs

@Inject
public FileTaskLogs(FileTaskLogsConfig config)

Method Detail

pushTaskLog

public void pushTaskLog(String taskid,
               File file)
                 throws IOException

Specified by:

pushTaskLog in interface io.druid.tasklogs.TaskLogPusher

Throws:

IOException

streamTaskLog

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

Specified by:

streamTaskLog in interface io.druid.tasklogs.TaskLogStreamer

Throws:

IOException