Package | Description |
---|---|
alluxio.client.block.util | |
alluxio.concurrent | |
alluxio.job.plan | |
alluxio.job.plan.load | |
alluxio.job.plan.migrate | |
alluxio.job.plan.persist | |
alluxio.job.plan.replicate | |
alluxio.job.plan.transform | |
alluxio.job.plan.transform.format.csv | |
alluxio.master.file | |
alluxio.master.file.meta | |
alluxio.master.table.transform | |
alluxio.security.authorization | |
alluxio.underfs | |
alluxio.underfs.hdfs | |
alluxio.underfs.hdfs.acl | |
alluxio.uri | |
alluxio.worker.block | |
alluxio.worker.block.evictor |
Set of evictors for evicting or moving blocks to other locations.
|
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 |
---|---|
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,ArrayList<LoadDefinition.LoadTask>>> |
LoadDefinition.selectExecutors(LoadConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Modifier and Type | Method and Description |
---|---|
Set<Pair<WorkerInfo,ArrayList<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<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 |
---|---|
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> |
HdfsAclProvider.getAcl(org.apache.hadoop.fs.FileSystem hdfs,
String path)
Returns the
AccessControlList from an hdfs path. |
Pair<AccessControlList,DefaultAccessControlList> |
NoopHdfsAclProvider.getAcl(org.apache.hadoop.fs.FileSystem hdfs,
String 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 | 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 |
---|---|
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.