alluxio.client.block.stream

Class SharedGrpcDataReader.Factory

java.lang.Object

alluxio.client.block.stream.SharedGrpcDataReader.Factory

All Implemented Interfaces:

DataReader.Factory, java.io.Closeable, java.lang.AutoCloseable

Enclosing class:

SharedGrpcDataReader

public static class SharedGrpcDataReader.Factory
extends java.lang.Object
implements DataReader.Factory

Factory class to create SharedGrpcDataReaders.

Constructor Summary

Constructors

Constructor and Description
Factory(FileSystemContext context, WorkerNetAddress address, ReadRequest.Builder readRequestBuilder, long blockSize) Creates an instance of SharedGrpcDataReader.Factory for block reads.

Method Summary

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

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,
               ReadRequest.Builder readRequestBuilder,
               long blockSize)

Creates an instance of SharedGrpcDataReader.Factory for block reads.

Parameters:

context - the file system context

address - the worker address

readRequestBuilder - the builder of read request

blockSize - the block size

Method Detail

create

public DataReader create(long offset,
                         long len)
                  throws java.io.IOException

Description copied from interface: DataReader.Factory

Creates an instance of DataReader.

Specified by:

create in interface DataReader.Factory

Parameters:

offset - the stream offset

len - the length of the stream

Returns:

the created object

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException