io.druid.indexer.updater

Class HadoopConverterJob.ConvertingOutputFormat

java.lang.Object

org.apache.hadoop.mapreduce.OutputFormat<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

io.druid.indexer.updater.HadoopConverterJob.ConvertingOutputFormat

Enclosing class:

HadoopConverterJob

public static class HadoopConverterJob.ConvertingOutputFormat
extends org.apache.hadoop.mapreduce.OutputFormat<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	DATA_FILE_KEY
protected static String	DATA_SUCCESS_KEY
protected static String	PUBLISHED_SEGMENT_KEY

Constructor Summary

Constructors

Constructor and Description
ConvertingOutputFormat()

Method Summary

Modifier and Type	Method and Description
void	checkOutputSpecs(org.apache.hadoop.mapreduce.JobContext context)
org.apache.hadoop.mapreduce.OutputCommitter	getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>	getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context)

Methods inherited from class java.lang.Object

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

Field Detail

DATA_FILE_KEY

protected static final String DATA_FILE_KEY

See Also:

Constant Field Values

DATA_SUCCESS_KEY

protected static final String DATA_SUCCESS_KEY

See Also:

Constant Field Values

PUBLISHED_SEGMENT_KEY

protected static final String PUBLISHED_SEGMENT_KEY

See Also:

Constant Field Values

Constructor Detail

ConvertingOutputFormat

public ConvertingOutputFormat()

Method Detail

getRecordWriter

public org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text> getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                                                                              throws IOException,
                                                                                                                     InterruptedException

Specified by:

getRecordWriter in class org.apache.hadoop.mapreduce.OutputFormat<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

Throws:

IOException

InterruptedException

checkOutputSpecs

public void checkOutputSpecs(org.apache.hadoop.mapreduce.JobContext context)
                      throws IOException,
                             InterruptedException

Specified by:

checkOutputSpecs in class org.apache.hadoop.mapreduce.OutputFormat<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

Throws:

IOException

InterruptedException

getOutputCommitter

public org.apache.hadoop.mapreduce.OutputCommitter getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                               throws IOException,
                                                                      InterruptedException

Specified by:

getOutputCommitter in class org.apache.hadoop.mapreduce.OutputFormat<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

Throws:

IOException

InterruptedException