org.apache.drill.exec.store.easy.json

Class StatisticsCollectorImpl

java.lang.Object

org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter

org.apache.drill.exec.store.easy.json.StatisticsCollectorImpl

All Implemented Interfaces:

org.apache.drill.exec.store.StatisticsRecordCollector

public class StatisticsCollectorImpl
extends org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	StatisticsCollectorImpl.BigIntJsonConverter
class	StatisticsCollectorImpl.DateJsonConverter
class	StatisticsCollectorImpl.IntJsonConverter
class	StatisticsCollectorImpl.NullableBigIntJsonConverter
class	StatisticsCollectorImpl.NullableFloat8JsonConverter
class	StatisticsCollectorImpl.NullableVarBinaryJsonConverter
class	StatisticsCollectorImpl.VarCharJsonConverter

Nested classes/interfaces inherited from class org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter

org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.BitJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.Decimal18JsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.Decimal28DenseJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.Decimal28SparseJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.Decimal38DenseJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.Decimal38SparseJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.Decimal9JsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.Float4JsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.Float8JsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.IntervalDayJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.IntervalJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.IntervalYearJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.NullableBitJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.NullableDateJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.NullableDecimal18JsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.NullableDecimal28DenseJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.NullableDecimal28SparseJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.NullableDecimal38DenseJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.NullableDecimal38SparseJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.NullableDecimal9JsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.NullableFloat4JsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.NullableIntervalDayJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.NullableIntervalJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.NullableIntervalYearJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.NullableIntJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.NullableSmallIntJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.NullableTimeJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.NullableTimeStampJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.NullableTinyIntJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.NullableUInt1JsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.NullableUInt2JsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.NullableUInt4JsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.NullableUInt8JsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.NullableVar16CharJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.NullableVarCharJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.NullableVarDecimalJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.RepeatedBigIntJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.RepeatedBitJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.RepeatedDateJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.RepeatedDecimal18JsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.RepeatedDecimal28DenseJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.RepeatedDecimal28SparseJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.RepeatedDecimal38DenseJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.RepeatedDecimal38SparseJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.RepeatedDecimal9JsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.RepeatedFloat4JsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.RepeatedFloat8JsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.RepeatedIntervalDayJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.RepeatedIntervalJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.RepeatedIntervalYearJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.RepeatedIntJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.RepeatedSmallIntJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.RepeatedTimeJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.RepeatedTimeStampJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.RepeatedTinyIntJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.RepeatedUInt1JsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.RepeatedUInt2JsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.RepeatedUInt4JsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.RepeatedUInt8JsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.RepeatedVar16CharJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.RepeatedVarBinaryJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.RepeatedVarCharJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.RepeatedVarDecimalJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.SmallIntJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.TimeJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.TimeStampJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.TinyIntJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.UInt1JsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.UInt2JsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.UInt4JsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.UInt8JsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.Var16CharJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.VarBinaryJsonConverter, org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter.VarDecimalJsonConverter

Field Summary

Fields inherited from class org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter

gen, skipNullFields

Constructor Summary

Constructors

Constructor and Description
StatisticsCollectorImpl()

Method Summary

Modifier and Type	Method and Description
void	endStatisticsRecord()
org.apache.drill.exec.store.EventBasedRecordWriter.FieldConverter	getNewBigIntConverter(int fieldId, String fieldName, FieldReader reader)
org.apache.drill.exec.store.EventBasedRecordWriter.FieldConverter	getNewDateConverter(int fieldId, String fieldName, FieldReader reader)
org.apache.drill.exec.store.EventBasedRecordWriter.FieldConverter	getNewIntConverter(int fieldId, String fieldName, FieldReader reader)
org.apache.drill.exec.store.EventBasedRecordWriter.FieldConverter	getNewNullableBigIntConverter(int fieldId, String fieldName, FieldReader reader)
org.apache.drill.exec.store.EventBasedRecordWriter.FieldConverter	getNewNullableFloat8Converter(int fieldId, String fieldName, FieldReader reader)
org.apache.drill.exec.store.EventBasedRecordWriter.FieldConverter	getNewNullableVarBinaryConverter(int fieldId, String fieldName, FieldReader reader)
org.apache.drill.exec.store.EventBasedRecordWriter.FieldConverter	getNewVarCharConverter(int fieldId, String fieldName, FieldReader reader)
DrillStatsTable.TableStatistics	getStatistics()
boolean	hasErrors()
boolean	hasStatistics()
void	startStatisticsRecord()

Methods inherited from class org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter

getNewBitConverter, getNewDecimal18Converter, getNewDecimal28DenseConverter, getNewDecimal28SparseConverter, getNewDecimal38DenseConverter, getNewDecimal38SparseConverter, getNewDecimal9Converter, getNewFloat4Converter, getNewFloat8Converter, getNewIntervalConverter, getNewIntervalDayConverter, getNewIntervalYearConverter, getNewNullableBitConverter, getNewNullableDateConverter, getNewNullableDecimal18Converter, getNewNullableDecimal28DenseConverter, getNewNullableDecimal28SparseConverter, getNewNullableDecimal38DenseConverter, getNewNullableDecimal38SparseConverter, getNewNullableDecimal9Converter, getNewNullableFloat4Converter, getNewNullableIntConverter, getNewNullableIntervalConverter, getNewNullableIntervalDayConverter, getNewNullableIntervalYearConverter, getNewNullableSmallIntConverter, getNewNullableTimeConverter, getNewNullableTimeStampConverter, getNewNullableTinyIntConverter, getNewNullableUInt1Converter, getNewNullableUInt2Converter, getNewNullableUInt4Converter, getNewNullableUInt8Converter, getNewNullableVar16CharConverter, 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, getNewVarDecimalConverter

Methods inherited from class java.lang.Object

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

Constructor Detail

StatisticsCollectorImpl

public StatisticsCollectorImpl()

Method Detail

startStatisticsRecord

public void startStatisticsRecord()

endStatisticsRecord

public void endStatisticsRecord()

hasStatistics

public boolean hasStatistics()

getStatistics

public DrillStatsTable.TableStatistics getStatistics()

hasErrors

public boolean hasErrors()

getNewBigIntConverter

public org.apache.drill.exec.store.EventBasedRecordWriter.FieldConverter getNewBigIntConverter(int fieldId,
                                                                                               String fieldName,
                                                                                               FieldReader reader)

Specified by:

getNewBigIntConverter in interface org.apache.drill.exec.store.StatisticsRecordCollector

Overrides:

getNewBigIntConverter in class org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter

getNewIntConverter

public org.apache.drill.exec.store.EventBasedRecordWriter.FieldConverter getNewIntConverter(int fieldId,
                                                                                            String fieldName,
                                                                                            FieldReader reader)

Specified by:

getNewIntConverter in interface org.apache.drill.exec.store.StatisticsRecordCollector

Overrides:

getNewIntConverter in class org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter

getNewDateConverter

public org.apache.drill.exec.store.EventBasedRecordWriter.FieldConverter getNewDateConverter(int fieldId,
                                                                                             String fieldName,
                                                                                             FieldReader reader)

Specified by:

getNewDateConverter in interface org.apache.drill.exec.store.StatisticsRecordCollector

Overrides:

getNewDateConverter in class org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter

getNewVarCharConverter

public org.apache.drill.exec.store.EventBasedRecordWriter.FieldConverter getNewVarCharConverter(int fieldId,
                                                                                                String fieldName,
                                                                                                FieldReader reader)

Specified by:

getNewVarCharConverter in interface org.apache.drill.exec.store.StatisticsRecordCollector

Overrides:

getNewVarCharConverter in class org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter

getNewNullableBigIntConverter

public org.apache.drill.exec.store.EventBasedRecordWriter.FieldConverter getNewNullableBigIntConverter(int fieldId,
                                                                                                       String fieldName,
                                                                                                       FieldReader reader)

Specified by:

getNewNullableBigIntConverter in interface org.apache.drill.exec.store.StatisticsRecordCollector

Overrides:

getNewNullableBigIntConverter in class org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter

getNewNullableVarBinaryConverter

public org.apache.drill.exec.store.EventBasedRecordWriter.FieldConverter getNewNullableVarBinaryConverter(int fieldId,
                                                                                                          String fieldName,
                                                                                                          FieldReader reader)

Specified by:

getNewNullableVarBinaryConverter in interface org.apache.drill.exec.store.StatisticsRecordCollector

Overrides:

getNewNullableVarBinaryConverter in class org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter

getNewNullableFloat8Converter

public org.apache.drill.exec.store.EventBasedRecordWriter.FieldConverter getNewNullableFloat8Converter(int fieldId,
                                                                                                       String fieldName,
                                                                                                       FieldReader reader)

Specified by:

getNewNullableFloat8Converter in interface org.apache.drill.exec.store.StatisticsRecordCollector

Overrides:

getNewNullableFloat8Converter in class org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter