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.TargetsMixin
static class
JetCommandLine.Verbosity
-
Constructor Summary
Constructors Constructor Description JetCommandLine(Function<ClientConfig,JetInstance> jetClientFn, PrintStream out, PrintStream err)
-
Method Summary
-
Constructor Details
-
JetCommandLine
public JetCommandLine(Function<ClientConfig,JetInstance> jetClientFn, PrintStream out, PrintStream err)
-
-
Method Details
-
main
-
run
public void run() -
sql
-
submit
public void submit(JetCommandLine.Verbosity verbosity, JetCommandLine.TargetsMixin targets, String snapshotName, String name, String mainClass, File file, List<String> params) throws Exception- Throws:
Exception
-
suspend
public void suspend(JetCommandLine.Verbosity verbosity, JetCommandLine.TargetsMixin targets, String name) -
cancel
public void cancel(JetCommandLine.Verbosity verbosity, JetCommandLine.TargetsMixin targets, String name) -
saveSnapshot
public void saveSnapshot(JetCommandLine.Verbosity verbosity, JetCommandLine.TargetsMixin targets, String jobName, String snapshotName, boolean isTerminal) -
deleteSnapshot
public void deleteSnapshot(JetCommandLine.Verbosity verbosity, JetCommandLine.TargetsMixin targets, String snapshotName) -
restart
public void restart(JetCommandLine.Verbosity verbosity, JetCommandLine.TargetsMixin targets, String name) -
resume
public void resume(JetCommandLine.Verbosity verbosity, JetCommandLine.TargetsMixin targets, String name) -
listJobs
public void listJobs(JetCommandLine.Verbosity verbosity, JetCommandLine.TargetsMixin targets, boolean listAll) -
listSnapshots
public void listSnapshots(JetCommandLine.Verbosity verbosity, JetCommandLine.TargetsMixin targets, boolean fullJobName) -
cluster
-