Package | Description |
---|---|
org.apache.drill.exec.record | |
org.apache.drill.exec.store.parquet.columnreaders.batchsizing | |
org.apache.drill.exec.util.record |
Modifier and Type | Field and Description |
---|---|
protected RecordBatchStats.RecordBatchStatsContext |
AbstractRecordBatch.batchStatsContext |
Modifier and Type | Method and Description |
---|---|
RecordBatchStats.RecordBatchStatsContext |
AbstractRecordBatch.getRecordBatchStatsContext() |
Modifier and Type | Method and Description |
---|---|
RecordBatchStats.RecordBatchStatsContext |
RecordBatchSizerManager.getBatchStatsContext() |
Modifier and Type | Method and Description |
---|---|
static RecordBatchOverflow.Builder |
RecordBatchOverflow.newBuilder(BufferAllocator allocator,
RecordBatchStats.RecordBatchStatsContext batchStatsContext) |
Constructor and Description |
---|
RecordBatchSizerManager(OptionManager options,
ParquetSchema schema,
long totalRecordsToRead,
RecordBatchStats.RecordBatchStatsContext batchStatsContext)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
static void |
RecordBatchStats.logRecordBatchStats(RecordBatchStats.RecordBatchIOType ioType,
RecordBatch recordBatch,
RecordBatchStats.RecordBatchStatsContext batchStatsContext) |
static void |
RecordBatchStats.logRecordBatchStats(RecordBatchStats.RecordBatchIOType ioType,
RecordBatchSizer recordBatchSizer,
RecordBatchStats.RecordBatchStatsContext batchStatsContext) |
static void |
RecordBatchStats.logRecordBatchStats(RecordBatchStats.RecordBatchIOType ioType,
String sourceId,
RecordBatch recordBatch,
RecordBatchStats.RecordBatchStatsContext batchStatsContext) |
static void |
RecordBatchStats.logRecordBatchStats(RecordBatchStats.RecordBatchIOType ioType,
String sourceId,
RecordBatchSizer batchSizer,
RecordBatchStats.RecordBatchStatsContext batchStatsContext)
Logs record batch statistics for the input record batch (logging happens only
when record statistics logging is enabled).
|
static void |
RecordBatchStats.logRecordBatchStats(RecordBatchStats.RecordBatchStatsContext batchStatsContext,
String format,
Object... args)
Logs a generic batch statistics message
|
static void |
RecordBatchStats.logRecordBatchStats(String message,
RecordBatchStats.RecordBatchStatsContext batchStatsContext)
Logs a generic batch statistics message
|
static void |
RecordBatchStats.printConfiguredBatchSize(RecordBatchStats.RecordBatchStatsContext batchStatsContext,
int batchSize)
Prints the configured batch size
|
Copyright © 1970 The Apache Software Foundation. All rights reserved.