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 and Description
static class	JetCommandLine.HazelcastVersionProvider
static class	JetCommandLine.TargetsMixin
static class	JetCommandLine.Verbosity

Constructor Summary

Constructors

Constructor and Description
JetCommandLine(Function<ClientConfig,JetInstance> jetClientFn, PrintStream out, PrintStream err)

Method Summary

Modifier and Type	Method and Description
void	cancel(JetCommandLine.Verbosity verbosity, JetCommandLine.TargetsMixin targets, String name)
void	cluster(JetCommandLine.Verbosity verbosity, JetCommandLine.TargetsMixin targets)
void	deleteSnapshot(JetCommandLine.Verbosity verbosity, JetCommandLine.TargetsMixin targets, String snapshotName)
void	listJobs(JetCommandLine.Verbosity verbosity, JetCommandLine.TargetsMixin targets, boolean listAll)
void	listSnapshots(JetCommandLine.Verbosity verbosity, JetCommandLine.TargetsMixin targets, boolean fullJobName)
static void	main(String[] args)
void	restart(JetCommandLine.Verbosity verbosity, JetCommandLine.TargetsMixin targets, String name)
void	resume(JetCommandLine.Verbosity verbosity, JetCommandLine.TargetsMixin targets, String name)
void	run()
void	saveSnapshot(JetCommandLine.Verbosity verbosity, JetCommandLine.TargetsMixin targets, String jobName, String snapshotName, boolean isTerminal)
void	sql(JetCommandLine.Verbosity verbosity, JetCommandLine.TargetsMixin targets)
void	submit(JetCommandLine.Verbosity verbosity, JetCommandLine.TargetsMixin targets, String snapshotName, String name, String mainClass, File file, List<String> params)
void	suspend(JetCommandLine.Verbosity verbosity, JetCommandLine.TargetsMixin targets, String name)

Methods inherited from class java.lang.Object

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

Constructor Detail

JetCommandLine

public JetCommandLine(Function<ClientConfig,JetInstance> jetClientFn,
                      PrintStream out,
                      PrintStream err)

Method Detail

main

public static void main(String[] args)

run

public void run()

Specified by:

run in interface Runnable

sql

public void sql(JetCommandLine.Verbosity verbosity,
                JetCommandLine.TargetsMixin targets)

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

public void cluster(JetCommandLine.Verbosity verbosity,
                    JetCommandLine.TargetsMixin targets)