package rpc_parallel

You can search for identifiers within the package.

in-package search v0.2.0

rpc_parallel
- CHANGES
- LICENSE
- Library rpc_parallel
  - Rpc_parallel
    
    Remote_executable
    
    Executable_location
    
    Fd_redirection
    
    Managed
    
    Map_reduce
    
    Config
    
    Worker
    
    Map_function
    
    Param
    
    Input
    
    Output
    
    Worker
    
    Map_function_with_init_spec
    
    Param
    
    Input
    
    Output
    
    Make_map_function_with_init
    
    Param
    
    Input
    
    Output
    
    Worker
    
    Map_function_spec
    
    Input
    
    Output
    
    Make_map_function
    
    Param
    
    Input
    
    Output
    
    Worker
    
    Map_reduce_function
    
    Param
    
    Accum
    
    Input
    
    Worker
    
    Map_reduce_function_with_init_spec
    
    Param
    
    Accum
    
    Input
    
    Make_map_reduce_function_with_init
    
    Param
    
    Accum
    
    Input
    
    Worker
    
    Map_reduce_function_spec
    
    Accum
    
    Input
    
    Make_map_reduce_function
    
    Param
    
    Accum
    
    Input
    
    Worker
    
    Function
    
    Worker
    
    Functions
    
    Creator
    
    Worker_spec
    
    Make
    
    State
    
    For_testing
    
    Expert
    
    Std
    
    Parallel
    
    Function
    
    Direct_pipe
    
    Worker
    
    Id
    
    Connection
    
    Shutdown_on
    
    Spawn_in_foreground_result
    
    Spawn_in_foreground_exn_result
    
    Deprecated
    
    Functions
    
    Creator
    
    Worker_spec
    
    Worker_state
    
    Connection_state
    
    Functions
    
    Make
    
    Id
    
    Connection
    
    Shutdown_on
    
    Spawn_in_foreground_result
    
    Spawn_in_foreground_exn_result
    
    Deprecated
    
    State
    
    For_testing
    
    Expert
    
    Worker_env
    
    Parallel_managed
    
    Worker
    
    Id
    
    Make
    
    Id
- Sources
  - rpc_parallel
    
    executable_location.ml
    
    fd_redirection.ml
    
    for_testing_internal.ml
    
    map_reduce.ml
    
    parallel.ml
    
    parallel_intf.ml
    
    parallel_managed.ml
    
    remote_executable.ml
    
    rpc_parallel.ml
    
    rpc_parallel__.ml
    
    utils.ml

Legend:
Page
Library
Module
Module type
Parameter
Class
Class type
Source

Module `Map_reduce.Config`

type t

val create : 
  ?local:int ->
  ?remote:(_ Remote_executable.t * int) list ->
  ?cd:string ->
  redirect_stderr:[ `Dev_null | `File_append of string ] ->
  redirect_stdout:[ `Dev_null | `File_append of string ] ->
  unit ->
  t

Default is to create the same number of local workers as the cores in local machine. All spawned workers will their redirect stdout and stderr to the same file.

package rpc_parallel

Module Map_reduce.Config

Module `Map_reduce.Config`