Package 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	Description
IcebergBlockMapBuilder(org.apache.hadoop.fs.FileSystem fs, Collection<CoordinationProtos.DrillbitEndpoint> endpoints)

Method Summary

Modifier and Type	Method	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 Details

IcebergBlockMapBuilder

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

Method Details

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