Package org.apache.drill.exec.store

Class EventBasedRecordWriter

java.lang.Object

org.apache.drill.exec.store.EventBasedRecordWriter

public class EventBasedRecordWriter
extends Object

Reads records from the RecordValueAccessor and writes into RecordWriter.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	EventBasedRecordWriter.FieldConverter

Constructor Summary

Constructors

Constructor	Description
EventBasedRecordWriter(VectorAccessible batch, RecordWriter recordWriter)

Method Summary

Modifier and Type	Method	Description
static EventBasedRecordWriter.FieldConverter	getConverter(RecordWriter recordWriter, int fieldId, String fieldName, FieldReader reader)
int	write(int recordCount)

Methods inherited from class java.lang.Object

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

Constructor Details

EventBasedRecordWriter

public EventBasedRecordWriter(VectorAccessible batch,
 RecordWriter recordWriter)
                       throws IOException

Throws:

IOException

Method Details

write

public int write(int recordCount)
          throws IOException

Throws:

IOException

getConverter

public static EventBasedRecordWriter.FieldConverter getConverter(RecordWriter recordWriter,
 int fieldId,
 String fieldName,
 FieldReader reader)