StatisticsCollectorImpl (Drill : 1.20.3 API)

java.lang.Object
- org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter
- - org.apache.drill.exec.store.easy.json.StatisticsCollectorImpl

All Implemented Interfaces:: StatisticsRecordCollector

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

Field Summary
- Fields inherited from class org.apache.drill.exec.store.JSONBaseStatisticsRecordWriter
  gen, skipNullFields

Constructor Summary

Constructors
Constructor and Description

StatisticsCollectorImpl()

Constructors
Constructor and Description
`StatisticsCollectorImpl()`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`endStatisticsRecord()` Called after adding all fields in a particular statistics record are added using add{TypeHolder}(fieldId, TypeHolder) methods.
`EventBasedRecordWriter.FieldConverter`	`getNewBigIntConverter(int fieldId, String fieldName, FieldReader reader)` Add the field value given in `valueHolder` at the given column number `fieldId`.
`EventBasedRecordWriter.FieldConverter`	`getNewDateConverter(int fieldId, String fieldName, FieldReader reader)` Add the field value given in `valueHolder` at the given column number `fieldId`.
`EventBasedRecordWriter.FieldConverter`	`getNewIntConverter(int fieldId, String fieldName, FieldReader reader)` Add the field value given in `valueHolder` at the given column number `fieldId`.
`EventBasedRecordWriter.FieldConverter`	`getNewNullableBigIntConverter(int fieldId, String fieldName, FieldReader reader)` Add the field value given in `valueHolder` at the given column number `fieldId`.
`EventBasedRecordWriter.FieldConverter`	`getNewNullableFloat8Converter(int fieldId, String fieldName, FieldReader reader)` Add the field value given in `valueHolder` at the given column number `fieldId`.
`EventBasedRecordWriter.FieldConverter`	`getNewNullableVarBinaryConverter(int fieldId, String fieldName, FieldReader reader)` Add the field value given in `valueHolder` at the given column number `fieldId`.
`EventBasedRecordWriter.FieldConverter`	`getNewVarCharConverter(int fieldId, String fieldName, FieldReader reader)` Add the field value given in `valueHolder` at the given column number `fieldId`.
`DrillStatsTable.TableStatistics`	`getStatistics()` Returns `DrillStatsTable.TableStatistics` instance with statistics collected using this `StatisticsRecordCollector`.
`boolean`	`hasErrors()`
`boolean`	`hasStatistics()` Returns true if this `StatisticsRecordCollector` has non-empty statistics.
`void`	`startStatisticsRecord()` Called before starting writing fields in a record.

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()
```
Description copied from interface: StatisticsRecordCollector

Called before starting writing fields in a record.

endStatisticsRecord
```
public void endStatisticsRecord()
```
Description copied from interface: StatisticsRecordCollector

Called after adding all fields in a particular statistics record are added using add{TypeHolder}(fieldId, TypeHolder) methods.

hasStatistics
```
public boolean hasStatistics()
```
Description copied from interface: StatisticsRecordCollector

Returns true if this StatisticsRecordCollector has non-empty statistics.

Returns:

if this StatisticsRecordCollector has non-empty statistics

getStatistics
```
public DrillStatsTable.TableStatistics getStatistics()
```
Description copied from interface: StatisticsRecordCollector

Returns DrillStatsTable.TableStatistics instance with statistics collected using this StatisticsRecordCollector.

Returns:

DrillStatsTable.TableStatistics instance

hasErrors
```
public boolean hasErrors()
```