Uses of Class
de.uni_kiel.rz.fdr.repl.REPLJob
Packages that use REPLJob
-
Uses of REPLJob in de.uni_kiel.rz.fdr.repl
Methods in de.uni_kiel.rz.fdr.repl that return REPLJobModifier and TypeMethodDescriptionstatic REPLJobGet a loaded job by key.REPLJob.JobEvent.job()Returns the value of thejobrecord component.static REPLJobLoads an archived job without preparing it for resuming.static REPLJobLoads an archived job without preparing it for resuming.static REPLJobREPLJob.repljob(groovy.lang.Closure<Serializable> closure, List<Serializable> inputs) Creates a new job with inputs and no concurrency that is ready to be started.static REPLJobREPLJob.repljob(groovy.lang.Closure<Serializable> closure, List<Serializable> inputs, int concurrency) Creates a new job with inputs that is ready to be started.static REPLJobREPLJob.repljob(groovy.lang.Closure<Serializable> closure, List<Serializable> inputs, int concurrency, String name) Creates a new job with inputs that is ready to be started.static REPLJobREPLJob.repljob(groovy.lang.Closure<Serializable> closure, List<Serializable> inputs, int concurrency, String name, boolean becomeDelegate) Creates a new job with inputs that is ready to be started.static REPLJobREPLJob.repljob(groovy.lang.Closure<Serializable> closure, List<Serializable> inputs, String name) Creates a new job with inputs and no concurrency that is ready to be started.static REPLJobREPLJob.repljob(BiFunction<Serializable, REPLJob, Serializable> function, List<Serializable> inputs) Creates a new job with inputs or concurrency that is ready to be started.static REPLJobREPLJob.repljob(BiFunction<Serializable, REPLJob, Serializable> function, List<Serializable> inputs, int concurrency) Creates a new job with inputs that is ready to be started.static REPLJobREPLJob.repljob(BiFunction<Serializable, REPLJob, Serializable> function, List<Serializable> inputs, int concurrency, String name) Creates a new job with inputs that is ready to be started.static REPLJobREPLJob.repljob(BiFunction<Serializable, REPLJob, Serializable> function, List<Serializable> inputs, String name) Creates a new job with inputs and no concurrency that is ready to be started.static REPLJobREPLJob.repljob(Supplier<Serializable> supplier) Creates a new job without inputs or concurrency that is ready to be started.static REPLJobREPLJob.repljob(Supplier<Serializable> supplier, int concurrency) Creates a new job without inputs that is ready to be started.static REPLJobREPLJob.repljob(Supplier<Serializable> supplier, String name) Creates a new job without inputs or concurrency that is ready to be started.static REPLJobREPLJob.resume(File path, groovy.lang.Closure<Serializable> closure) Loads an archived job instance and prepares unfinished and unsuccessful inputs for resuming.static REPLJobREPLJob.resume(File path, groovy.lang.Closure<Serializable> closure, boolean retrySuccess, boolean retryErrors) Loads an archived job instance and prepares it for resuming.static REPLJobREPLJob.resume(File path, groovy.lang.Closure<Serializable> closure, boolean retrySuccess, boolean retryErrors, boolean becomeDelegate) Loads an archived job instance and prepares it for resuming.static REPLJobREPLJob.resume(File path, BiFunction<Serializable, REPLJob, Serializable> function) Loads an archived job instance and prepares unfinished and unsuccessful inputs for resuming.static REPLJobREPLJob.resume(File path, BiFunction<Serializable, REPLJob, Serializable> function, boolean retrySuccess, boolean retryErrors) Loads an archived job instance and prepares it for resuming.static REPLJobREPLJob.resume(File path, Supplier<Serializable> supplier) Loads an archived job instance and prepares unfinished and unsuccessful inputs for resuming.static REPLJobREPLJob.resume(File path, Supplier<Serializable> supplier, boolean retrySuccess, boolean retryErrors) Loads an archived job instance and prepares it for resuming.static REPLJobREPLJob.resume(String key, groovy.lang.Closure<Serializable> closure) Loads an archived job instance and prepares unfinished and unsuccessful inputs for resuming.static REPLJobREPLJob.resume(String key, groovy.lang.Closure<Serializable> closure, boolean retrySuccess, boolean retryErrors) Loads an archived job instance and prepares it for resuming.static REPLJobREPLJob.resume(String key, groovy.lang.Closure<Serializable> closure, boolean retrySuccess, boolean retryErrors, boolean becomeDelegate) Loads an archived job instance and prepares it for resuming.static REPLJobREPLJob.resume(String key, BiFunction<Serializable, REPLJob, Serializable> function) Loads an archived job instance and prepares unfinished and unsuccessful inputs for resuming.static REPLJobREPLJob.resume(String key, BiFunction<Serializable, REPLJob, Serializable> function, boolean retrySuccess, boolean retryErrors) Loads an archived job instance and prepares it for resuming.static REPLJobREPLJob.resume(String key, Supplier<Serializable> supplier) Loads an archived job instance and prepares unfinished and unsuccessful inputs for resuming.static REPLJobREPLJob.resume(String key, Supplier<Serializable> supplier, boolean retrySuccess, boolean retryErrors) Loads an archived job instance and prepares it for resuming.Methods in de.uni_kiel.rz.fdr.repl that return types with arguments of type REPLJobModifier and TypeMethodDescriptionREPLJob.list()Get the list of all jobs that are not archived - that is: loaded in memory.REPLJob.streamArchived()Stream all archived jobs without adding them to the list of active jobs.Methods in de.uni_kiel.rz.fdr.repl with parameters of type REPLJobModifier and TypeMethodDescriptionstatic booleanArchives a loaded job.Method parameters in de.uni_kiel.rz.fdr.repl with type arguments of type REPLJobModifier and TypeMethodDescriptionstatic REPLJobREPLJob.repljob(BiFunction<Serializable, REPLJob, Serializable> function, List<Serializable> inputs) Creates a new job with inputs or concurrency that is ready to be started.static REPLJobREPLJob.repljob(BiFunction<Serializable, REPLJob, Serializable> function, List<Serializable> inputs, int concurrency) Creates a new job with inputs that is ready to be started.static REPLJobREPLJob.repljob(BiFunction<Serializable, REPLJob, Serializable> function, List<Serializable> inputs, int concurrency, String name) Creates a new job with inputs that is ready to be started.static REPLJobREPLJob.repljob(BiFunction<Serializable, REPLJob, Serializable> function, List<Serializable> inputs, String name) Creates a new job with inputs and no concurrency that is ready to be started.static REPLJobREPLJob.resume(File path, BiFunction<Serializable, REPLJob, Serializable> function) Loads an archived job instance and prepares unfinished and unsuccessful inputs for resuming.static REPLJobREPLJob.resume(File path, BiFunction<Serializable, REPLJob, Serializable> function, boolean retrySuccess, boolean retryErrors) Loads an archived job instance and prepares it for resuming.static REPLJobREPLJob.resume(String key, BiFunction<Serializable, REPLJob, Serializable> function) Loads an archived job instance and prepares unfinished and unsuccessful inputs for resuming.static REPLJobREPLJob.resume(String key, BiFunction<Serializable, REPLJob, Serializable> function, boolean retrySuccess, boolean retryErrors) Loads an archived job instance and prepares it for resuming.Constructors in de.uni_kiel.rz.fdr.repl with parameters of type REPLJobModifierConstructorDescriptionJobEvent(REPLJob job, Instant timestamp, REPLJob.JobEventType eventType, Integer inputIndex) Creates an instance of aJobEventrecord class.