org.apache.hadoop.hive.druid.io

Class DruidRecordWriter

java.lang.Object

org.apache.hadoop.hive.druid.io.DruidRecordWriter

All Implemented Interfaces:

FileSinkOperator.RecordWriter, org.apache.hadoop.mapred.RecordWriter<org.apache.hadoop.io.NullWritable,DruidWritable>

public class DruidRecordWriter
extends Object
implements org.apache.hadoop.mapred.RecordWriter<org.apache.hadoop.io.NullWritable,DruidWritable>, FileSinkOperator.RecordWriter

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
DruidRecordWriter(io.druid.segment.indexing.DataSchema dataSchema, io.druid.segment.indexing.RealtimeTuningConfig realtimeTuningConfig, io.druid.segment.loading.DataSegmentPusher dataSegmentPusher, int maxPartitionSize, org.apache.hadoop.fs.Path segmentsDescriptorsDir, org.apache.hadoop.fs.FileSystem fileSystem)

Method Summary

Modifier and Type	Method and Description
void	close(boolean abort)
void	close(org.apache.hadoop.mapred.Reporter reporter)
void	write(org.apache.hadoop.io.NullWritable key, DruidWritable value)
void	write(org.apache.hadoop.io.Writable w)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final org.slf4j.Logger LOG

Constructor Detail

DruidRecordWriter

public DruidRecordWriter(io.druid.segment.indexing.DataSchema dataSchema,
                         io.druid.segment.indexing.RealtimeTuningConfig realtimeTuningConfig,
                         io.druid.segment.loading.DataSegmentPusher dataSegmentPusher,
                         int maxPartitionSize,
                         org.apache.hadoop.fs.Path segmentsDescriptorsDir,
                         org.apache.hadoop.fs.FileSystem fileSystem)

Method Detail

write

public void write(org.apache.hadoop.io.Writable w)
           throws IOException

Specified by:

write in interface FileSinkOperator.RecordWriter

Throws:

IOException

close

public void close(boolean abort)
           throws IOException

Specified by:

close in interface FileSinkOperator.RecordWriter

Throws:

IOException

write

public void write(org.apache.hadoop.io.NullWritable key,
                  DruidWritable value)
           throws IOException

Specified by:

write in interface org.apache.hadoop.mapred.RecordWriter<org.apache.hadoop.io.NullWritable,DruidWritable>

Throws:

IOException

close

public void close(org.apache.hadoop.mapred.Reporter reporter)
           throws IOException

Specified by:

close in interface org.apache.hadoop.mapred.RecordWriter<org.apache.hadoop.io.NullWritable,DruidWritable>

Throws:

IOException