alluxio.client.file.dora

Class DoraCachePositionReader

java.lang.Object

alluxio.client.file.dora.DoraCachePositionReader

All Implemented Interfaces:

PositionReader, Closeable, AutoCloseable

@ThreadSafe
public class DoraCachePositionReader
extends Object
implements PositionReader

Implementation of PositionReader that reads data through network from source.

Constructor Summary

Constructors

Constructor and Description
DoraCachePositionReader(PositionReader dataReader, long length, Optional<CloseableSupplier<PositionReader>> fallbackReader)

Method Summary

Modifier and Type	Method and Description
void	close() Closes the positon reader and do cleanup job if any.
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

read, read, read, read, read

Constructor Detail

DoraCachePositionReader

public DoraCachePositionReader(PositionReader dataReader,
                               long length,
                               Optional<CloseableSupplier<PositionReader>> fallbackReader)

Parameters:

dataReader - reader to read data through network

length - file length

fallbackReader - the position reader to fallback to when errors happen, or none if no fallback read is needed

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

close

public void close()
           throws IOException

Description copied from interface: PositionReader

Closes the positon reader and do cleanup job if any.

Specified by:

close in interface PositionReader

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException