• General
• FAQ
• Setup & Configuration
• Local Setup
• Cluster Setup
• Stratosphere on YARN
• Configuration
• Programming Guides
• Java API
• Scala API
• Iterations
• Spargel
• Examples
• Programming Model
• Meteor Query Language
• Program Execution
• Local Executor/Debugging
• Remote Excecutor
• Commandline Client
• Web Interface

CLI Client

Stratosphere provides a commandline client to:

• submit jobs for execution,
• cancel a running job,
• provide information about a job, and
• list running and waiting jobs.

Usage

The client is used as follows:

./stratosphere [ACTION] [GENERAL_OPTIONS] [ACTION_ARGUMENTS]
  general options:
     -h,--help      Show the help for the CLI Frontend.
     -v,--verbose   Print more detailed error messages.

Action "run" compiles and submits a Stratosphere program.
  "run" action arguments:
     -a,--arguments <programArgs>   Program arguments
     -c,--class <classname>         Program class
     -j,--jarfile <jarfile>         Stratosphere program JAR file
     -m,--jobmanager <host:port>    Jobmanager to which the program is submitted
     -w,--wait                      Wait for program to finish

Action "info" displays information about a Stratosphere program.
  "info" action arguments:
     -a,--arguments <programArgs>   Program arguments
     -c,--class <classname>         Program class
     -d,--description               Show description of expected program arguments
     -j,--jarfile <jarfile>         Stratosphere program JAR file
     -p,--plan                      Show optimized execution plan of the
                                    program (JSON)

Action "list" lists submitted Stratosphere programs.
  "list" action arguments:
     -r,--running     Show running programs and their JobIDs
     -s,--scheduled   Show scheduled prorgrams and their JobIDs

Action "cancel" cancels a submitted Stratosphere program.
  "cancel" action arguments:
     -i,--jobid <jobID>   JobID of program to cancel

Example Usage:

• Run WordCount example program on the JobManager configured in /conf/stratosphere.yaml:

  ./bin/stratosphere run -j ./examples/stratosphere-java-examples-0.4-WordCount.jar \
                         -a 4 file:///home/user/hamlet.txt file:///home/user/wordcount_out
  

• Run WordCount example program on a specific JobManager:

  ./bin/stratosphere run -m myJMHost:6123 \
                         -j ./examples/stratosphere-java-examples-0.4-WordCount.jar \
                         -a 4 file:///home/user/hamlet.txt file:///home/user/wordcount_out
  

• Run WordCount example program (program class not defined in the JAR file manifest):

  ./bin/stratosphere run -j ./examples/stratosphere-java-examples-0.4-WordCount.jar \
                         -c eu.stratosphere.example.java.record.wordcount.WordCount \
                         -a 4 file:///home/user/hamlet.txt file:///home/user/wordcount_out
  

• Display the expected arguments for the WordCount example program:

  ./bin/stratosphere info -d \
                          -j ./examples/stratosphere-java-examples-0.4-WordCount.jar
  

• Display the optimized execution plan for the WordCount example program as JSON:

  ./bin/stratosphere info -p \
                          -j ./examples/stratosphere-java-examples-0.4-WordCount.jar \
                          -a 4 file:///home/user/hamlet.txt file:///home/user/wordcount_out
  

• List scheduled and running jobs (including their JobIDs):

  ./bin/stratosphere list -s \
                          -r
  

• Cancel a job:

  ./bin/stratosphere cancel -i <jobID>