io.druid.storage.azure

Class AzureTaskLogs

java.lang.Object

io.druid.storage.azure.AzureTaskLogs

All Implemented Interfaces:

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

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

Constructor Summary

Constructors

Constructor and Description
AzureTaskLogs(AzureTaskLogsConfig config, AzureStorage azureStorage)

Method Summary

Methods

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

AzureTaskLogs

@Inject
public AzureTaskLogs(AzureTaskLogsConfig config,
                    AzureStorage azureStorage)

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