Package | Description |
---|---|
alluxio.client.block.stream | |
alluxio.client.file |
Constructor and Description |
---|
Factory(BlockWorker blockWorker,
long blockId,
long chunkSize,
InStreamOptions options)
Creates an instance of
BlockWorkerDataReader.Factory . |
Modifier and Type | Method and Description |
---|---|
Optional<BlockWorker> |
FileSystemContext.getProcessLocalWorker()
Acquires the internal block worker as a gateway for worker internal clients to communicate
with the local worker directly without going through external RPC frameworks.
|
Modifier and Type | Method and Description |
---|---|
static FileSystemContext |
FileSystemContext.create(ClientContext ctx,
BlockWorker blockWorker) |
FileSystemContext |
FileSystemContext.FileSystemContextFactory.create(ClientContext ctx,
BlockWorker blockWorker) |
static FileSystemContext |
FileSystemContext.create(ClientContext ctx,
BlockWorker blockWorker,
List<InetSocketAddress> masterAddresses) |
FileSystemContext |
FileSystemContext.FileSystemContextFactory.create(ClientContext ctx,
BlockWorker blockWorker,
List<InetSocketAddress> masterAddresses) |
Constructor and Description |
---|
FileSystemContext(AlluxioConfiguration conf,
BlockWorker blockWorker,
List<InetSocketAddress> masterAddresses)
Initializes FileSystemContext ID.
|
Copyright © 2023. All Rights Reserved.