Modifier and Type | Method and Description |
---|---|
List<Pair<BlockStoreLocation,BlockStoreLocation>> |
DefaultStorageTierAssoc.intersectionList() |
List<Pair<BlockStoreLocation,BlockStoreLocation>> |
StorageTierAssoc.intersectionList() |
Modifier and Type | Method and Description |
---|---|
protected Pair<String,String> |
HdfsConfValidationTask.getHdfsConfPaths() |
Modifier and Type | Method and Description |
---|---|
protected Pair<ValidationTaskResult,org.apache.hadoop.hive.metastore.IMetaStoreClient> |
CreateHmsClientValidationTask.getValidationWithResult() |
Modifier and Type | Method and Description |
---|---|
Map<Long,List<Pair<InetSocketAddress,WorkerInfo>>> |
AllMastersWorkerInfo.getWorkerIdInfoMap() |
Constructor and Description |
---|
AllMastersWorkerInfo(Map<Long,InetSocketAddress> workerIdAddressMap,
List<InetSocketAddress> masterAddresses,
InetSocketAddress primaryMasterAddress,
List<WorkerInfo> primaryMasterWorkerInfo,
Map<Long,List<Pair<InetSocketAddress,WorkerInfo>>> workerIdInfoMap) |
Modifier and Type | Method and Description |
---|---|
Pair<URIStatus,String> |
DoraCacheClient.createFile(String path,
CreateFilePOptions options)
Create File.
|
Modifier and Type | Method and Description |
---|---|
Pair<AccessControlList,DefaultAccessControlList> |
ManagedBlockingUfsForwarder.getAclPair(String path) |
Modifier and Type | Field and Description |
---|---|
protected List<Pair<String,String>> |
MountCliOptions.mMountOptions |
Modifier and Type | Method and Description |
---|---|
Set<Pair<WorkerInfo,SerializableVoid>> |
NoopPlanDefinition.selectExecutors(NoopPlanConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext selectExecutorsContext) |
Set<Pair<WorkerInfo,P>> |
PlanDefinition.selectExecutors(T config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext selectExecutorsContext)
Selects the workers to run the task.
|
Modifier and Type | Method and Description |
---|---|
Set<Pair<WorkerInfo,BatchedJobDefinition.BatchedJobTask>> |
BatchedJobDefinition.selectExecutors(BatchedJobConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Modifier and Type | Method and Description |
---|---|
Set<Pair<WorkerInfo,MigrateCommand>> |
MigrateDefinition.selectExecutors(MigrateConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context)
Selects the workers to run the task.
|
Modifier and Type | Method and Description |
---|---|
Set<Pair<WorkerInfo,SerializableVoid>> |
PersistDefinition.selectExecutors(PersistConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Modifier and Type | Method and Description |
---|---|
Set<Pair<WorkerInfo,SerializableVoid>> |
MoveDefinition.selectExecutors(MoveConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Modifier and Type | Method and Description |
---|---|
Set<Pair<WorkerInfo,ArrayList<String>>> |
StressBenchDefinition.selectExecutors(StressBenchConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Constructor and Description |
---|
SafeUfsDeleter(MountTable mountTable,
ReadOnlyInodeStore inodeStore,
List<Pair<AlluxioURI,LockedInodePath>> inodes,
DeletePOptions deleteOptions)
Creates a new instance of
SafeUfsDeleter . |
Modifier and Type | Class and Description |
---|---|
class |
InodePathPair
This class represents a pair of
LockedInodePath s. |
Modifier and Type | Method and Description |
---|---|
Optional<Pair<Long,Long>> |
UfsSyncPathCache.getSyncTimesForPath(AlluxioURI path)
Get sync times for a given path if they exist in the cache.
|
Modifier and Type | Method and Description |
---|---|
void |
MigrateCliRunner.setJobConfigAndFileMetrics(List<Pair<String,String>> filePath,
boolean overwrite,
WriteType writeType,
CmdRunAttempt attempt)
Create a JobConfig and set file count and size for the Migrate job.
|
Modifier and Type | Method and Description |
---|---|
Pair<org.rocksdb.RocksDB,AtomicReference<org.rocksdb.ColumnFamilyHandle>> |
RocksInodeStore.getDBInodeColumn()
A testing only method to access the internal objects.
|
Modifier and Type | Method and Description |
---|---|
Pair<AccessControlList,DefaultAccessControlList> |
DefaultAccessControlList.generateChildDirACL(Short umask)
Creates a child directory's access ACL and default ACL based on the default ACL.
|
Modifier and Type | Method and Description |
---|---|
static Pair<List<String>,List<String>> |
Parameters.partitionFieldNames(List<Parameters> paramList) |
Modifier and Type | Field and Description |
---|---|
static Pair<AccessControlList,DefaultAccessControlList> |
BaseUnderFileSystem.EMPTY_ACL |
Modifier and Type | Method and Description |
---|---|
Pair<AccessControlList,DefaultAccessControlList> |
BaseUnderFileSystem.getAclPair(String path) |
Pair<AccessControlList,DefaultAccessControlList> |
UnderFileSystemWithLogging.getAclPair(String path) |
Pair<AccessControlList,DefaultAccessControlList> |
UnderFileSystem.getAclPair(String path)
Gets the ACL and the Default ACL of a file or directory in under file system.
|
Modifier and Type | Method and Description |
---|---|
protected List<Pair<String,String>> |
ObjectUnderFileSystem.RenameBuffer.operate(List<Pair<String,String>> paths) |
Modifier and Type | Method and Description |
---|---|
protected List<Pair<String,String>> |
ObjectUnderFileSystem.RenameBuffer.operate(List<Pair<String,String>> paths) |
Modifier and Type | Method and Description |
---|---|
Pair<AccessControlList,DefaultAccessControlList> |
NoopHdfsAclProvider.getAcl(org.apache.hadoop.fs.FileSystem hdfs,
String path) |
Pair<AccessControlList,DefaultAccessControlList> |
HdfsAclProvider.getAcl(org.apache.hadoop.fs.FileSystem hdfs,
String path)
Returns the
AccessControlList from an hdfs path. |
Pair<AccessControlList,DefaultAccessControlList> |
HdfsUnderFileSystem.getAclPair(String path) |
Modifier and Type | Method and Description |
---|---|
Pair<AccessControlList,DefaultAccessControlList> |
SupportedHdfsAclProvider.getAcl(org.apache.hadoop.fs.FileSystem hdfs,
String path) |
Modifier and Type | Method and Description |
---|---|
static Pair<String,String> |
URI.Factory.getSchemeComponents(String scheme)
Returns a
Pair of components of the given scheme. |
Modifier and Type | Class and Description |
---|---|
class |
OperationId
Used as an unique ID wrapper.
|
Modifier and Type | Method and Description |
---|---|
Map<Pair<String,String>,Long> |
BlockStoreMeta.getCapacityBytesOnDirs() |
Map<Pair<String,String>,Long> |
BlockStoreMeta.getUsedBytesOnDirs() |
Copyright © 2023. All Rights Reserved.