alluxio.cli.bundler

Class CollectInfo

java.lang.Object

alluxio.cli.AbstractShell

alluxio.cli.bundler.CollectInfo

All Implemented Interfaces:

Closeable, AutoCloseable

public class CollectInfo
extends AbstractShell

Class for collecting various information about all nodes in the cluster.

Field Summary

Fields inherited from class alluxio.cli.AbstractShell

mCloser, mConfiguration

Constructor Summary

Constructors

Constructor and Description
CollectInfo(InstancedConfiguration alluxioConf) Creates a new instance of CollectInfo.

Method Summary

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.

Methods inherited from class alluxio.cli.AbstractShell

getCommands, printUsage, run

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CollectInfo

public CollectInfo(InstancedConfiguration alluxioConf)

Creates a new instance of CollectInfo.

Parameters:

alluxioConf - Alluxio configuration

Method Detail

getHosts

public Set<String> getHosts()

Finds all hosts in the Alluxio cluster. We assume the masters and workers cover all the nodes in the cluster. This command now relies on conf/masters and conf/workers to contain the nodes in the cluster. This is the same requirement as bin/alluxio-start.sh. TODO(jiacheng): phase 2 specify hosts from cmdline TODO(jiacheng): phase 2 cross-check with the master for which nodes are in the cluster

Returns:

a set of hostnames in the cluster

printHelp

public static void printHelp(String message)

Prints the help message.

Parameters:

message - message before standard usage information

main

public static void main(String[] argv)
                 throws IOException

Main method, starts a new CollectInfo shell. CollectInfo will SSH to all hosts and invoke 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.

Parameters:

argv - array of arguments given by the user's input from the terminal

Throws:

IOException

collectAllFutures

public static <T> CompletableFuture<List<T>> collectAllFutures(List<CompletableFuture<T>> futures)

Waits for ALL futures to complete and returns a list of results. If any future completes exceptionally then the resulting future will also complete exceptionally.

Type Parameters:

T - this is the type the CompletableFuture contains

Parameters:

futures - a list of futures to collect

Returns:

a CompletableFuture of all futures

getShellName

protected String getShellName()

Specified by:

getShellName in class AbstractShell

Returns:

name of the shell

loadCommands

protected Map<String,Command> loadCommands()

Description copied from class: AbstractShell

Map structure: Command name => Command instance.

Specified by:

loadCommands in class AbstractShell

Returns:

a set of commands which can be executed under this shell

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class AbstractShell

Throws:

IOException