alluxio.client.block.stream

Class LocalFilePacketReader.Factory

java.lang.Object

alluxio.client.block.stream.LocalFilePacketReader.Factory

All Implemented Interfaces:

PacketReader.Factory, Closeable, AutoCloseable

Enclosing class:

LocalFilePacketReader

@NotThreadSafe
public static class LocalFilePacketReader.Factory
extends Object
implements PacketReader.Factory

Factory class to create LocalFilePacketReaders.

Constructor Summary

Constructors

Constructor and Description
Factory(FileSystemContext context, WorkerNetAddress address, long blockId, long packetSize, InStreamOptions options) Creates an instance of LocalFilePacketReader.Factory.

Method Summary

Modifier and Type	Method and Description
void	close()
PacketReader	create(long offset, long len) Creates an instance of PacketReader.
boolean	isShortCircuit()

Methods inherited from class java.lang.Object

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

Constructor Detail

Factory

public Factory(FileSystemContext context,
               WorkerNetAddress address,
               long blockId,
               long packetSize,
               InStreamOptions options)
        throws IOException

Creates an instance of LocalFilePacketReader.Factory.

Parameters:

context - the file system context

address - the worker address

blockId - the block ID

packetSize - the packet size

options - the instream options

Throws:

IOException

Method Detail

create

public PacketReader create(long offset,
                           long len)
                    throws IOException

Description copied from interface: PacketReader.Factory

Creates an instance of PacketReader.

Specified by:

create in interface PacketReader.Factory

Parameters:

offset - the stream offset

len - the length of the stream

Returns:

the created object

Throws:

IOException

isShortCircuit

public boolean isShortCircuit()

Specified by:

isShortCircuit in interface PacketReader.Factory

Returns:

whether this factory generates packet readers which perform short-circuit reads

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException