Modifier and Type | Method and Description |
---|---|
List<Pair<BlockStoreLocation,BlockStoreLocation>> |
AbstractStorageTierAssoc.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 |
---|---|
Pair<WorkerNetAddress,BlockInStream.BlockInStreamSource> |
AlluxioBlockStore.getDataSourceAndType(BlockInfo info,
URIStatus status,
BlockLocationPolicy policy,
Map<WorkerNetAddress,Long> failedWorkers)
Gets the data source and type of data source of a block.
|
Modifier and Type | Method and Description |
---|---|
static Optional<Pair<WorkerNetAddress,Boolean>> |
BlockLocationUtils.nearest(TieredIdentity tieredIdentity,
List<WorkerNetAddress> addresses,
AlluxioConfiguration conf) |
Modifier and Type | Method and Description |
---|---|
Pair<AccessControlList,DefaultAccessControlList> |
ManagedBlockingUfsForwarder.getAclPair(String path) |
Modifier and Type | Method and Description |
---|---|
static Pair<String,String> |
PrestoCatalogUtils.getAlluxioUser()
Get Alluxio process user and group.
|
static Pair<String,String> |
PrestoCatalogUtils.getPrestoUser()
Get Presto process user and group.
|
static Pair<String,String> |
PrestoCatalogUtils.getProcessInfo(UploadProcessType type)
Get user info based on process type.
|
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,ArrayList<LoadDefinition.LoadTask>>> |
LoadDefinition.selectExecutors(LoadConfig 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>> |
EvictDefinition.selectExecutors(EvictConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Set<Pair<WorkerInfo,SerializableVoid>> |
MoveDefinition.selectExecutors(MoveConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Set<Pair<WorkerInfo,SerializableVoid>> |
ReplicateDefinition.selectExecutors(ReplicateConfig 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) |
Modifier and Type | Method and Description |
---|---|
Set<Pair<WorkerInfo,ArrayList<CompactTask>>> |
CompactDefinition.selectExecutors(CompactConfig config,
List<WorkerInfo> jobWorkers,
SelectExecutorsContext context) |
Modifier and Type | Method and Description |
---|---|
static Pair<Integer,Integer> |
Decimal.getPrecisionAndScale(String type)
Returns the decimal's precision and scale from the type definition.
|
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 |
---|---|
Pair<String,String> |
TransformJobInfo.getDbTable() |
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 | Method and Description |
---|---|
Pair<AccessControlList,DefaultAccessControlList> |
UnderFileSystemWithLogging.getAclPair(String path) |
Pair<AccessControlList,DefaultAccessControlList> |
BaseUnderFileSystem.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> |
DefaultBlockStoreMeta.getCapacityBytesOnDirs() |
Map<Pair<String,String>,Long> |
BlockStoreMeta.getCapacityBytesOnDirs() |
Map<Pair<String,String>,Long> |
DefaultBlockStoreMeta.getUsedBytesOnDirs() |
Map<Pair<String,String>,Long> |
BlockStoreMeta.getUsedBytesOnDirs() |
Modifier and Type | Method and Description |
---|---|
Pair<List<Long>,List<Long>> |
EmulatingBlockIterator.getSwaps(BlockStoreLocation srcLocation,
BlockOrder srcOrder,
BlockStoreLocation dstLocation,
BlockOrder dstOrder,
int swapRange,
BlockOrder intersectionOrder,
java.util.function.Function<Long,Boolean> blockFilterFunc) |
Pair<List<Long>,List<Long>> |
DefaultBlockIterator.getSwaps(BlockStoreLocation srcLocation,
BlockOrder srcOrder,
BlockStoreLocation dstLocation,
BlockOrder dstOrder,
int swapRange,
BlockOrder intersectionOrder,
java.util.function.Function<Long,Boolean> blockFilterFunc) |
Pair<List<Long>,List<Long>> |
BlockIterator.getSwaps(BlockStoreLocation srcLocation,
BlockOrder srcOrder,
BlockStoreLocation dstLocation,
BlockOrder dstOrder,
int swapRange,
BlockOrder intersectionOrder,
java.util.function.Function<Long,Boolean> blockFilterFunc)
Used to list of blocks, that if swapped, could eliminate overlap between two tiers.
|
Modifier and Type | Method and Description |
---|---|
Iterator<Pair<Long,T>> |
SortedBlockSet.getAscendingIterator() |
Iterator<Pair<Long,T>> |
SortedBlockSet.getDescendingIterator() |
Modifier and Type | Method and Description |
---|---|
void |
LRFUAnnotator.updateSortedFields(List<Pair<Long,LRFUAnnotator.LRFUSortedField>> blockList) |
void |
LRUAnnotator.updateSortedFields(List<Pair<Long,LRUAnnotator.LRUSortedField>> blocks) |
void |
BlockAnnotator.updateSortedFields(List<Pair<Long,T>> blockList)
Updates sorted-field values for all {block-id, sorted-field} pairs
at the same logical time.
|
Modifier and Type | Method and Description |
---|---|
List<Pair<Long,BlockStoreLocation>> |
EvictionPlan.toEvict() |
Constructor and Description |
---|
EvictionPlan(List<BlockTransferInfo> toTransfer,
List<Pair<Long,BlockStoreLocation>> toEvict)
Creates a new instance of
EvictionPlan . |
Copyright © 2023. All Rights Reserved.