public class CollectInfo extends AbstractShell
mCloser, mConfiguration
Constructor and Description |
---|
CollectInfo(InstancedConfiguration alluxioConf)
Creates a new instance of
CollectInfo . |
Modifier and Type | Method and Description |
---|---|
void |
close() |
static <T> CompletableFuture<List<T>> |
collectAllFutures(List<CompletableFuture<T>> futures)
Waits for ALL futures to complete and returns a list of results.
|
Set<String> |
getHosts()
Finds all hosts in the Alluxio cluster.
|
protected String |
getShellName() |
protected Map<String,Command> |
loadCommands()
Map structure: Command name =>
Command instance. |
static void |
main(String[] argv)
Main method, starts a new CollectInfo shell.
|
static void |
printHelp(String message)
Prints the help message.
|
getCommands, printUsage, run
public CollectInfo(InstancedConfiguration alluxioConf)
CollectInfo
.alluxioConf
- Alluxio configurationpublic Set<String> getHosts()
public static void printHelp(String message)
message
- message before standard usage informationpublic static void main(String[] argv) throws IOException
CollectInfo
with --local option.
Then collect the tarballs generated on each of the hosts to the localhost.
And tarball all results into one final tarball.argv
- array of arguments given by the user's input from the terminalIOException
public static <T> CompletableFuture<List<T>> collectAllFutures(List<CompletableFuture<T>> futures)
T
- this is the type the CompletableFuture
containsfutures
- a list of futures to collectCompletableFuture
of all futuresprotected String getShellName()
getShellName
in class AbstractShell
protected Map<String,Command> loadCommands()
AbstractShell
Command
instance.loadCommands
in class AbstractShell
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in class AbstractShell
IOException
Copyright © 2023. All Rights Reserved.