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 | Field and Description |
---|---|
Map<Scheduler.WorkerInfoIdentity,CloseableResource<BlockWorkerClient>> |
Scheduler.WorkerInfoHub.mActiveWorkers |
Modifier and Type | Method and Description |
---|---|
CloseableResource<BlockWorkerClient> |
MembershipManagerWorkerProvider.getWorkerClient(WorkerNetAddress address) |
CloseableResource<BlockWorkerClient> |
DefaultWorkerProvider.getWorkerClient(WorkerNetAddress address) |
CloseableResource<BlockWorkerClient> |
WorkerProvider.getWorkerClient(WorkerNetAddress address)
Gets a worker client.
|
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. |
class |
PooledResource<T>
A pooled resource that was acquired from a
Pool , and will be released back
to the pool when it's closed. |
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> |
UfsFileWriteRequestContext.getUfsResource() |
Modifier and Type | Method and Description |
---|---|
void |
UfsFileWriteRequestContext.setUfsResource(CloseableResource<UnderFileSystem> ufsResource) |
Copyright © 2023. All Rights Reserved.