com.asakusafw.runtime.directio.hadoop

Class BlockMap

java.lang.Object

com.asakusafw.runtime.directio.hadoop.BlockMap

public final class BlockMap
extends Object

Utilities for file blocks.

Since:

0.7.0

See Also:

BlockInfo

Method Summary

Modifier and Type	Method and Description
static List<BlockInfo>	computeBlocks(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.FileStatus status) Returns a list of BlockInfo for the target file.
static BlockMap	create(String path, long fileSize, Collection<BlockInfo> blockList, boolean combineBlocks) Create BlockMap.
DirectInputFragment	get(long start, long end) Returns DirectInputFragment for the range.
List<BlockInfo>	getBlocks() Returns the file blocks in this map.
long	getFileSize() Returns the file size.

Methods inherited from class java.lang.Object

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

Method Detail

getFileSize

public long getFileSize()

Returns the file size.

Returns:

the size

getBlocks

public List<BlockInfo> getBlocks()

Returns the file blocks in this map.

Returns:

the file blocks

computeBlocks

public static List<BlockInfo> computeBlocks(org.apache.hadoop.fs.FileSystem fs,
                                            org.apache.hadoop.fs.FileStatus status)
                                     throws IOException

Returns a list of BlockInfo for the target file.

Parameters:

fs - the target file

status - the target file status

Returns:

the computed information

Throws:

IOException - if failed to compute information

create

public static BlockMap create(String path,
                              long fileSize,
                              Collection<BlockInfo> blockList,
                              boolean combineBlocks)

Create BlockMap.

Parameters:

path - the target file path

fileSize - the target file size

blockList - the original block list

combineBlocks - true to combine consecutive blocks with same owners

Returns:

the built object

get

public DirectInputFragment get(long start,
                               long end)

Returns DirectInputFragment for the range.

Parameters:

start - the start offset (inclusive)

end - the end offset (exclusive)

Returns:

the computed fragment