Package com.hazelcast.jet.server
Class JetCommandLine
java.lang.Object
com.hazelcast.jet.server.JetCommandLine
- All Implemented Interfaces:
Runnable
public class JetCommandLine extends Object implements Runnable
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
JetCommandLine.JetVersionProvider
static class
JetCommandLine.Verbosity
-
Constructor Summary
Constructors Constructor Description JetCommandLine(Function<ClientConfig,JetInstance> jetClientFn, PrintStream out, PrintStream err)
-
Method Summary
Modifier and Type Method Description void
cancel(JetCommandLine.Verbosity verbosity, String name)
void
cluster(JetCommandLine.Verbosity verbosity)
void
deleteSnapshot(JetCommandLine.Verbosity verbosity, String snapshotName)
void
listJobs(JetCommandLine.Verbosity verbosity, boolean listAll)
void
listSnapshots(JetCommandLine.Verbosity verbosity, boolean fullJobName)
static void
main(String[] args)
void
restart(JetCommandLine.Verbosity verbosity, String name)
void
resume(JetCommandLine.Verbosity verbosity, String name)
void
run()
void
saveSnapshot(JetCommandLine.Verbosity verbosity, String jobName, String snapshotName, boolean isTerminal)
void
submit(JetCommandLine.Verbosity verbosity, String snapshotName, String name, String mainClass, File file, List<String> params)
void
suspend(JetCommandLine.Verbosity verbosity, String name)
-
Constructor Details
-
JetCommandLine
public JetCommandLine(Function<ClientConfig,JetInstance> jetClientFn, PrintStream out, PrintStream err)
-
-
Method Details
-
main
-
run
public void run() -
submit
public void submit(JetCommandLine.Verbosity verbosity, String snapshotName, String name, String mainClass, File file, List<String> params) throws Exception- Throws:
Exception
-
suspend
- Throws:
IOException
-
cancel
- Throws:
IOException
-
saveSnapshot
public void saveSnapshot(JetCommandLine.Verbosity verbosity, String jobName, String snapshotName, boolean isTerminal) throws IOException- Throws:
IOException
-
deleteSnapshot
public void deleteSnapshot(JetCommandLine.Verbosity verbosity, String snapshotName) throws IOException- Throws:
IOException
-
restart
- Throws:
IOException
-
resume
- Throws:
IOException
-
listJobs
- Throws:
IOException
-
listSnapshots
public void listSnapshots(JetCommandLine.Verbosity verbosity, boolean fullJobName) throws IOException- Throws:
IOException
-
cluster
- Throws:
IOException
-