Package org.apache.drill.exec.store

Class StatisticsRecordWriterImpl

java.lang.Object

org.apache.drill.exec.store.StatisticsRecordWriterImpl

public class StatisticsRecordWriterImpl
extends Object

Reads records from the RecordValueAccessor and writes into StatisticsRecordCollector.

Constructor Summary

Constructors

Constructor	Description
StatisticsRecordWriterImpl(VectorAccessible batch, StatisticsRecordWriter recordWriter)

Method Summary

Modifier and Type	Method	Description
void	flushBlockingWriter()
static EventBasedRecordWriter.FieldConverter	getConverter(StatisticsRecordCollector recordWriter, int fieldId, String fieldName, FieldReader reader)
int	writeStatistics(int recordCount)

Methods inherited from class java.lang.Object

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

Constructor Details

StatisticsRecordWriterImpl

public StatisticsRecordWriterImpl(VectorAccessible batch,
 StatisticsRecordWriter recordWriter)
                           throws IOException

Throws:

IOException

Method Details

writeStatistics

public int writeStatistics(int recordCount)
                    throws IOException

Throws:

IOException

flushBlockingWriter

public void flushBlockingWriter()
                         throws IOException

Throws:

IOException

getConverter

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