io.druid.storage.hdfs.tasklog

Class HdfsTaskLogs

java.lang.Object

io.druid.storage.hdfs.tasklog.HdfsTaskLogs

All Implemented Interfaces:

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

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

Indexer hdfs task logs, to support storing hdfs tasks to hdfs.

Constructor Summary

Constructors

Constructor and Description
HdfsTaskLogs(HdfsTaskLogsConfig config, org.apache.hadoop.conf.Configuration hadoopConfig)

Method Summary

Modifier and Type	Method and Description
void	pushTaskLog(String taskId, File logFile)
com.google.common.base.Optional<com.google.common.io.ByteSource>	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

HdfsTaskLogs

@Inject
public HdfsTaskLogs(HdfsTaskLogsConfig config,
                            org.apache.hadoop.conf.Configuration hadoopConfig)

Method Detail

pushTaskLog

public void pushTaskLog(String taskId,
                        File logFile)
                 throws IOException

Specified by:

pushTaskLog in interface io.druid.tasklogs.TaskLogPusher

Throws:

IOException

streamTaskLog

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

Specified by:

streamTaskLog in interface io.druid.tasklogs.TaskLogStreamer

Throws:

IOException