org.apache.drill.exec.store

Interface StatisticsRecordWriter

All Superinterfaces:

org.apache.drill.exec.store.StatisticsRecordCollector

All Known Implementing Classes:

JsonStatisticsRecordWriter

public interface StatisticsRecordWriter
extends org.apache.drill.exec.store.StatisticsRecordCollector

Method Summary

Modifier and Type	Method and Description
void	abort()
void	checkForNewPartition(int index) Check if the writer should start a new partition, and if so, start a new partition
void	cleanup()
void	flushBlockingWriter() For a blocking writer, called after processing all the records to flush out the writes
void	init(Map<String,String> writerOptions) Initialize the writer.
boolean	isBlockingWriter() Returns if the writer is a blocking writer i.e.
void	updateSchema(VectorAccessible batch) Update the schema in RecordWriter.

Methods inherited from interface org.apache.drill.exec.store.StatisticsRecordCollector

endStatisticsRecord, getNewBigIntConverter, getNewBitConverter, getNewDateConverter, getNewDecimal18Converter, getNewDecimal28DenseConverter, getNewDecimal28SparseConverter, getNewDecimal38DenseConverter, getNewDecimal38SparseConverter, getNewDecimal9Converter, getNewFloat4Converter, getNewFloat8Converter, getNewIntConverter, getNewIntervalConverter, getNewIntervalDayConverter, getNewIntervalYearConverter, getNewNullableBigIntConverter, getNewNullableBitConverter, getNewNullableDateConverter, getNewNullableDecimal18Converter, getNewNullableDecimal28DenseConverter, getNewNullableDecimal28SparseConverter, getNewNullableDecimal38DenseConverter, getNewNullableDecimal38SparseConverter, getNewNullableDecimal9Converter, getNewNullableFloat4Converter, getNewNullableFloat8Converter, getNewNullableIntConverter, getNewNullableIntervalConverter, getNewNullableIntervalDayConverter, getNewNullableIntervalYearConverter, getNewNullableSmallIntConverter, getNewNullableTimeConverter, getNewNullableTimeStampConverter, getNewNullableTinyIntConverter, getNewNullableUInt1Converter, getNewNullableUInt2Converter, getNewNullableUInt4Converter, getNewNullableUInt8Converter, getNewNullableVar16CharConverter, getNewNullableVarBinaryConverter, getNewNullableVarCharConverter, getNewNullableVarDecimalConverter, getNewRepeatedBigIntConverter, getNewRepeatedBitConverter, getNewRepeatedDateConverter, getNewRepeatedDecimal18Converter, getNewRepeatedDecimal28DenseConverter, getNewRepeatedDecimal28SparseConverter, getNewRepeatedDecimal38DenseConverter, getNewRepeatedDecimal38SparseConverter, getNewRepeatedDecimal9Converter, getNewRepeatedFloat4Converter, getNewRepeatedFloat8Converter, getNewRepeatedIntConverter, getNewRepeatedIntervalConverter, getNewRepeatedIntervalDayConverter, getNewRepeatedIntervalYearConverter, getNewRepeatedSmallIntConverter, getNewRepeatedTimeConverter, getNewRepeatedTimeStampConverter, getNewRepeatedTinyIntConverter, getNewRepeatedUInt1Converter, getNewRepeatedUInt2Converter, getNewRepeatedUInt4Converter, getNewRepeatedUInt8Converter, getNewRepeatedVar16CharConverter, getNewRepeatedVarBinaryConverter, getNewRepeatedVarCharConverter, getNewRepeatedVarDecimalConverter, getNewSmallIntConverter, getNewTimeConverter, getNewTimeStampConverter, getNewTinyIntConverter, getNewUInt1Converter, getNewUInt2Converter, getNewUInt4Converter, getNewUInt8Converter, getNewVar16CharConverter, getNewVarBinaryConverter, getNewVarCharConverter, getNewVarDecimalConverter, getStatistics, hasStatistics, startStatisticsRecord

Method Detail

init

void init(Map<String,String> writerOptions)

Initialize the writer.

Parameters:

writerOptions - Contains key, value pair of settings.

Throws:

IOException

updateSchema

void updateSchema(VectorAccessible batch)

Update the schema in RecordWriter. Called at least once before starting writing the records.

Parameters:

batch -

Throws:

IOException

checkForNewPartition

void checkForNewPartition(int index)

Check if the writer should start a new partition, and if so, start a new partition

isBlockingWriter

boolean isBlockingWriter()

Returns if the writer is a blocking writer i.e. consumes all input before writing it out

Returns:

TRUE, if writer is blocking. FALSE, otherwise

flushBlockingWriter

void flushBlockingWriter()
                  throws IOException

For a blocking writer, called after processing all the records to flush out the writes

Throws:

IOException

abort

void abort()

cleanup

void cleanup()