alluxio.underfs.local

Class LocalPositionReader

java.lang.Object

alluxio.underfs.local.LocalPositionReader

All Implemented Interfaces:

PositionReader, Closeable, AutoCloseable

@ThreadSafe
public class LocalPositionReader
extends Object
implements PositionReader

Implementation of PositionReader that reads from local UFS.

Constructor Summary

Constructors

Constructor and Description
LocalPositionReader(String path, long fileLength)

Method Summary

Modifier and Type	Method and Description
int	readInternal(long position, ReadTargetBuffer buffer, int length)

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.PositionReader

close, read, read, read, read, read

Constructor Detail

LocalPositionReader

public LocalPositionReader(String path,
                           long fileLength)

Parameters:

path - the local file path

fileLength - the file length

Method Detail

readInternal

public int readInternal(long position,
                        ReadTargetBuffer buffer,
                        int length)
                 throws IOException

Specified by:

readInternal in interface PositionReader

Parameters:

position - position of the file to start reading data

buffer - target byte buffer

length - bytes to read

Returns:

bytes read, or -1 none of data is read

Throws:

IOException