| Package | Description |
|---|---|
| org.apache.drill.exec.store.kafka |
Kafka storage plugin.
|
| org.apache.drill.exec.store.parquet | |
| org.apache.drill.exec.store.schedule |
| Modifier and Type | Method and Description |
|---|---|
EndpointByteMap |
KafkaGroupScan.PartitionScanWork.getByteMap() |
| Constructor and Description |
|---|
PartitionScanWork(EndpointByteMap byteMap,
KafkaPartitionScanSpec partitionScanSpec) |
| Modifier and Type | Method and Description |
|---|---|
EndpointByteMap |
RowGroupInfo.getByteMap() |
| Modifier and Type | Method and Description |
|---|---|
void |
RowGroupInfo.setEndpointByteMap(EndpointByteMap byteMap) |
| Modifier and Type | Class and Description |
|---|---|
class |
EndpointByteMapImpl |
| Modifier and Type | Method and Description |
|---|---|
EndpointByteMap |
CompleteFileWork.getByteMap() |
EndpointByteMap |
CompleteWork.getByteMap() |
EndpointByteMap |
BlockMapBuilder.getEndpointByteMap(Set<String> noDrillbitHosts,
FileWork work)
For a given FileWork, calculate how many bytes are available on each on drillbit endpoint
|
| Constructor and Description |
|---|
CompleteFileWork(EndpointByteMap byteMap,
long start,
long length,
org.apache.hadoop.fs.Path path) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.