Package | Description |
---|---|
alluxio.client.block.stream | |
alluxio.client.file | |
alluxio.client.job | |
alluxio.master.file.meta | |
alluxio.resource | |
alluxio.table.under.hive.util | |
alluxio.underfs | |
alluxio.worker.grpc |
Constructor and Description |
---|
BufferCachingGrpcDataReader(WorkerNetAddress address,
CloseableResource<BlockWorkerClient> client,
long dataTimeoutMs,
ReadRequest readRequest,
GrpcBlockingStream<ReadRequest,ReadResponse> stream)
Creates an instance of
BufferCachingGrpcDataReader . |
Modifier and Type | Method and Description |
---|---|
CloseableResource<BlockMasterClient> |
FileSystemContext.acquireBlockMasterClientResource()
Acquires a block master client resource from the block master client pool.
|
CloseableResource<BlockWorkerClient> |
FileSystemContext.acquireBlockWorkerClient(WorkerNetAddress workerNetAddress)
Acquires a block worker client from the client pools.
|
CloseableResource<FileSystemMasterClient> |
FileSystemContext.acquireMasterClientResource()
Acquires a file system master client from the file system master client pool.
|
Modifier and Type | Method and Description |
---|---|
CloseableResource<JobMasterClient> |
JobContext.acquireMasterClientResource()
Acquires a job master client from the job master client pool.
|
Modifier and Type | Method and Description |
---|---|
CloseableResource<UnderFileSystem> |
MountTable.Resolution.acquireUfsResource() |
Modifier and Type | Class and Description |
---|---|
class |
CloseableIterator<T>
A
CloseableIterator<T> is an iterator which requires cleanup when it is no longer in use. |
Modifier and Type | Method and Description |
---|---|
CloseableResource<org.apache.hadoop.hive.metastore.IMetaStoreClient> |
HiveClientPool.acquireClientResource() |
Modifier and Type | Method and Description |
---|---|
CloseableResource<UnderFileSystem> |
UfsManager.UfsClient.acquireUfsResource() |
Modifier and Type | Method and Description |
---|---|
CloseableResource<UnderFileSystem> |
UfsFileWriteRequestContext.getUfsResource() |
CloseableResource<UnderFileSystem> |
BlockWriteRequestContext.getUfsResource() |
Modifier and Type | Method and Description |
---|---|
void |
UfsFileWriteRequestContext.setUfsResource(CloseableResource<UnderFileSystem> ufsResource) |
void |
BlockWriteRequestContext.setUfsResource(CloseableResource<UnderFileSystem> ufsResource) |
Copyright © 2023. All Rights Reserved.