sig
type run_parameters
val name : string
val serialize : run_parameters -> string
val deserialize_exn : string -> run_parameters
val start :
run_parameters ->
host_io:Host_io.t ->
(run_parameters, Host_io.Error.classified) Unix_io.Deferred_result.t
val update :
run_parameters ->
host_io:Host_io.t ->
([ `Failed of run_parameters * string
| `Still_running of run_parameters
| `Succeeded of run_parameters ], Host_io.Error.classified)
Unix_io.Deferred_result.t
val kill :
run_parameters ->
host_io:Host_io.t ->
([ `Killed of run_parameters ], Host_io.Error.classified)
Unix_io.Deferred_result.t
val log :
run_parameters -> (string * Ketrew_pure.Internal_pervasives.Log.t) list
val additional_queries :
run_parameters -> (string * Ketrew_pure.Internal_pervasives.Log.t) list
val query :
run_parameters ->
host_io:Host_io.t ->
string ->
(string, Ketrew_pure.Internal_pervasives.Log.t) Unix_io.Deferred_result.t
type distributed_shell_parameters
val distributed_shell_program :
?hadoop_bin:string ->
?distributed_shell_shell_jar:string ->
?container_vcores:int ->
container_memory:[ `GB of int | `MB of int | `Raw of string ] ->
timeout:[ `Raw of string | `Seconds of int ] ->
application_name:string ->
Ketrew_pure.Program.t ->
[> `Distributed_shell of
Ketrew.Yarn.distributed_shell_parameters * Ketrew_pure.Program.t ]
val create :
?host:Ketrew_pure.Host.t ->
?daemonize_using:[ `Nohup_setsid | `Python_daemon ] ->
?daemon_start_timeout:float ->
[ `Distributed_shell of
Ketrew.Yarn.distributed_shell_parameters * Ketrew_pure.Program.t
| `Yarn_application of Ketrew_pure.Program.t ] ->
[> `Long_running of string * string ]
val max_name_length : int Pervasives.ref
end