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 |
NettyDataReader
A netty packet reader that streams a region from a netty data server.
|
class |
SharedGrpcDataReader
A shared gRPC data reader that cache blocks data for multi-thread accessing.
|
Modifier and Type | Method and Description |
---|---|
DataReader |
BlockWorkerDataReader.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 . |
DataReader |
GrpcDataReader.Factory.create(long offset,
long len) |
Copyright © 2023. All Rights Reserved.