val input_sexps : Async.Reader.t -> Async.Sexp.t list Async.Deferred.tval open_gzip_file : string -> Async.Reader.t Async.Deferred.tval with_input_from_process :
prog:string ->
args:string list ->
f:(Async.Reader.t -> 'a Async.Deferred.t) ->
'a Async.Deferred.tStart a process and read its stdout as input from a Reader.t.
If the process writes anything to stderr it will be thrown as an exception after reading is finished.
val with_gzip_file :
string ->
f:(Async.Reader.t -> 'a Async.Deferred.t) ->
'a Async.Deferred.tval with_hadoop_gzip_file :
hadoop_file:string ->
(Async.Reader.t -> 'a Async.Deferred.t) ->
'a Async.Deferred.tval with_xzip_file :
string ->
f:(Async.Reader.t -> 'a Async.Deferred.t) ->
'a Async.Deferred.t