alluxio.client.file.dora.netty

Class NettyDataReader

java.lang.Object

alluxio.client.file.dora.netty.NettyDataReader

All Implemented Interfaces:

PositionReader, Closeable, AutoCloseable

public class NettyDataReader
extends Object
implements PositionReader

Positioned Netty data reader.

Constructor Summary

Constructors

Constructor and Description
NettyDataReader(FileSystemContext context, WorkerNetAddress address, Protocol.ReadRequest.Builder requestBuilder) Constructor.

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

NettyDataReader

public NettyDataReader(FileSystemContext context,
                       WorkerNetAddress address,
                       Protocol.ReadRequest.Builder requestBuilder)

Constructor.

Parameters:

context -

address -

requestBuilder -

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