public final class DistributedLoadUtils extends Object
Modifier and Type | Method and Description |
---|---|
static void |
distributedLoad(AbstractDistributedJobCommand command,
AlluxioURI filePath,
int replication,
Set<String> workerSet,
Set<String> excludedWorkerSet,
Set<String> localityIds,
Set<String> excludedLocalityIds)
Distributed loads a file or directory in Alluxio space, makes it resident in memory.
|
public static void distributedLoad(AbstractDistributedJobCommand command, AlluxioURI filePath, int replication, Set<String> workerSet, Set<String> excludedWorkerSet, Set<String> localityIds, Set<String> excludedLocalityIds) throws AlluxioException, IOException
command
- The command to execute loadingfilePath
- The AlluxioURI
path to load into Alluxio memoryreplication
- Number of block replicas of each loaded fileworkerSet
- A set of worker hosts to load dataexcludedWorkerSet
- A set of worker hosts can not to load datalocalityIds
- The locality identify setexcludedLocalityIds
- A set of worker locality identify can not to load dataAlluxioException
IOException
Copyright © 2023. All Rights Reserved.