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

Method Summary

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

BlockMapBuilder

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

Method Detail

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