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 | Field and Description |
---|---|
protected CloseableResource<UnderFileSystem> |
UfsBaseFileSystem.mUfs |
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<Lock> |
FuseReadWriteLockManager.tryLock(String path,
LockMode mode)
Tries to lock the given poth with read/write mode.
|
Modifier and Type | Method and Description |
---|---|
CloseableResource<UnderFileSystem> |
MountTable.Resolution.acquireUfsResource() |
Modifier and Type | Method and Description |
---|---|
CloseableResource<BlockWorkerClient> |
DefaultWorkerProvider.getWorkerClient(WorkerNetAddress address) |
Modifier and Type | Method and Description |
---|---|
Map<WorkerInfo,CloseableResource<BlockWorkerClient>> |
Scheduler.getActiveWorkers()
Get active workers.
|
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<BlockWorkerClient> |
WorkerProvider.getWorkerClient(WorkerNetAddress address)
Gets a worker client.
|
Modifier and Type | Method and Description |
---|---|
CloseableResource<org.apache.hadoop.hive.metastore.IMetaStoreClient> |
DefaultHiveClientPool.acquireClientResource() |
abstract CloseableResource<org.apache.hadoop.hive.metastore.IMetaStoreClient> |
AbstractHiveClientPool.acquireClientResource() |
Modifier and Type | Method and Description |
---|---|
CloseableResource<UnderFileSystem> |
UfsManager.UfsClient.acquireUfsResource() |
Modifier and Type | Class and Description |
---|---|
class |
BlockLock
A resource lock for block.
|
Modifier and Type | Method and Description |
---|---|
CloseableResource<UnderFileSystem> |
BlockWriteRequestContext.getUfsResource() |
CloseableResource<UnderFileSystem> |
UfsFileWriteRequestContext.getUfsResource() |
Modifier and Type | Method and Description |
---|---|
void |
BlockWriteRequestContext.setUfsResource(CloseableResource<UnderFileSystem> ufsResource) |
void |
UfsFileWriteRequestContext.setUfsResource(CloseableResource<UnderFileSystem> ufsResource) |
Copyright © 2023. All Rights Reserved.