Package | Description |
---|---|
alluxio.client.block.stream |
Modifier and Type | Class and Description |
---|---|
class |
BlockWorkerDataReader
A data reader that reads from a worker in the same process of this client directly.
|
class |
GrpcDataReader
A gRPC data reader that streams a region from gRPC data server.
|
class |
LocalFileDataReader
A data reader that simply reads packets from a local file.
|
class |
SharedGrpcDataReader
A shared gRPC data reader that cache blocks data for multi-thread accessing.
|
Modifier and Type | Field and Description |
---|---|
protected DataReader |
BlockInStream.mDataReader |
Modifier and Type | Method and Description |
---|---|
DataReader |
GrpcDataReader.Factory.create(long offset,
long len) |
DataReader |
BlockWorkerDataReader.Factory.create(long offset,
long len) |
DataReader |
LocalFileDataReader.Factory.create(long offset,
long len) |
DataReader |
SharedGrpcDataReader.Factory.create(long offset,
long len) |
DataReader |
DataReader.Factory.create(long offset,
long len)
Creates an instance of
DataReader . |
Copyright © 2023. All Rights Reserved.