org.apache.drill.exec.store.iceberg

Class IcebergBlockMapBuilder

java.lang.Object

org.apache.drill.exec.store.iceberg.IcebergBlockMapBuilder

public class IcebergBlockMapBuilder
extends Object

Constructor Summary

Constructors

Constructor and Description
IcebergBlockMapBuilder(org.apache.hadoop.fs.FileSystem fs, Collection<CoordinationProtos.DrillbitEndpoint> endpoints)

Method Summary

Modifier and Type	Method and Description
List<IcebergCompleteWork>	generateFileWork(Iterable<org.apache.iceberg.CombinedScanTask> combinedScanTasks)
EndpointByteMap	getEndpointByteMap(org.apache.iceberg.CombinedScanTask scanTask) For a given FileWork, calculate how many bytes are available on each on drillbit endpoint

Methods inherited from class java.lang.Object

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

Constructor Detail

IcebergBlockMapBuilder

public IcebergBlockMapBuilder(org.apache.hadoop.fs.FileSystem fs,
                              Collection<CoordinationProtos.DrillbitEndpoint> endpoints)

Method Detail

generateFileWork

public List<IcebergCompleteWork> generateFileWork(Iterable<org.apache.iceberg.CombinedScanTask> combinedScanTasks)
                                           throws IOException

Throws:

IOException

getEndpointByteMap

public EndpointByteMap getEndpointByteMap(org.apache.iceberg.CombinedScanTask scanTask)
                                   throws IOException

For a given FileWork, calculate how many bytes are available on each on drillbit endpoint

Parameters:

scanTask - the CombinedScanTask to calculate endpoint bytes for

Throws:

IOException