Package org.apache.drill.exec.store.schedule

Class BlockMapBuilder

java.lang.Object

org.apache.drill.exec.store.schedule.BlockMapBuilder

public class BlockMapBuilder
extends Object

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
List<CompleteFileWork>	generateFileWork(List<org.apache.hadoop.fs.FileStatus> files, boolean blockify)
EndpointByteMap	getEndpointByteMap(Set<String> noDrillbitHosts, FileWork work)	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

BlockMapBuilder

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

Method Details

generateFileWork

public List<CompleteFileWork> generateFileWork(List<org.apache.hadoop.fs.FileStatus> files,
 boolean blockify)
                                        throws IOException

Throws:

IOException

getEndpointByteMap

public EndpointByteMap getEndpointByteMap(Set<String> noDrillbitHosts,
 FileWork work)
                                   throws IOException

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

Parameters:

work - the FileWork to calculate endpoint bytes for

Throws:

IOException