Package org.apache.druid.indexer.report

Class SingleFileTaskReportFileWriter

java.lang.Object

org.apache.druid.indexer.report.SingleFileTaskReportFileWriter

All Implemented Interfaces:

TaskReportFileWriter

public class SingleFileTaskReportFileWriter
extends Object
implements TaskReportFileWriter

Constructor Summary

Constructors

Constructor	Description
SingleFileTaskReportFileWriter(File reportsFile)

Method Summary

Modifier and Type	Method	Description
File	getReportsFile(String taskId)	Returns the reports file for the given taskId.
OutputStream	openReportOutputStream(String taskId)
void	setObjectMapper(com.fasterxml.jackson.databind.ObjectMapper objectMapper)
void	write(String taskId, TaskReport.ReportMap reports)
static void	writeReportToStream(com.fasterxml.jackson.databind.ObjectMapper objectMapper, OutputStream outputStream, TaskReport.ReportMap reports)

Methods inherited from class java.lang.Object

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

Constructor Details

SingleFileTaskReportFileWriter

public SingleFileTaskReportFileWriter(File reportsFile)

Method Details

write

public void write(String taskId,
 TaskReport.ReportMap reports)

Specified by:

write in interface TaskReportFileWriter

openReportOutputStream

public OutputStream openReportOutputStream(String taskId)
                                    throws IOException

Specified by:

openReportOutputStream in interface TaskReportFileWriter

Throws:

IOException

setObjectMapper

public void setObjectMapper(com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Specified by:

setObjectMapper in interface TaskReportFileWriter

getReportsFile

public File getReportsFile(String taskId)

Description copied from interface: TaskReportFileWriter

Returns the reports file for the given taskId. Returns null if writer does not write reports to any file.

Specified by:

getReportsFile in interface TaskReportFileWriter

writeReportToStream

public static void writeReportToStream(com.fasterxml.jackson.databind.ObjectMapper objectMapper,
 OutputStream outputStream,
 TaskReport.ReportMap reports)
                                throws Exception

Throws:

Exception