B | |
| BRowSet [Nn_commit_monitor] | |
| BlockRM [Nn_blocklist] |
Represents blocks from a single datanode as (index) ranges
start..end
|
| Blockinfo [Nn_blocklist] |
Keys are indexes!
|
| Brange [Plasma_blocks] |
block ranges can be merged and split
|
| Bset [Plasma_blocks] |
a set of block ranges
|
C | |
| Cmd_nfs3d | |
| Cmd_plasma | |
| Cmd_plasma_admin | |
| Cmd_plasma_convert | |
| Cmd_plasma_datanode_init | |
| Cmd_plasma_kv | |
| Cmd_plasmad | |
D | |
| DSeq [Mapred_toolkit] | |
| Dn_config |
The clustername
|
| Dn_io |
Returns this as factory for inclusion into
Netplex_main.startup
|
| Dn_manager |
Returns this as factory for inclusion into
Netplex_main.startup
|
| Dn_shm |
Shared memory for transmitting data from the main process to the
I/O processes and vice versa
|
| Dn_store |
The directory containing the store.
|
F | |
| Float_asc [Mapred_sorters] | |
| Float_desc [Mapred_sorters] | |
| Float_xdr_asc [Mapred_sorters] | |
| Float_xdr_desc [Mapred_sorters] | |
G | |
| Grouped [Mapred_sorters] | |
H | |
| Hex_asc [Mapred_sorters] | |
| Hex_desc [Mapred_sorters] | |
I | |
| I64Set [Nn_commit_monitor] | |
| Int64_xdr_asc [Mapred_sorters] | |
| Int64_xdr_desc [Mapred_sorters] | |
| Integer_asc [Mapred_sorters] | |
| Integer_desc [Mapred_sorters] | |
L | |
| Line_splitter [Platform] | |
M | |
| Mapred_auth |
Authentication in server context
|
| Mapred_config |
Configuration of mapred servers
|
| Mapred_def |
Defining the map/reduce job
|
| Mapred_fields |
Access to record fields
|
| Mapred_fs |
Filesystem abstraction
|
| Mapred_io |
Utility library for record-based I/O
|
| Mapred_io_bgreader |
Background reader for
Mapred_io
|
| Mapred_job |
Run a map/red job
|
| Mapred_job_config |
Extract job configuration, and marshalling
|
| Mapred_job_exec |
Execute a scheduled job by submitting tasks to servers
|
| Mapred_main |
Main program for the task server and job controller, for this
single job only
|
| Mapred_rfun |
Registered functions (low-level)
|
| Mapred_sched |
Scheduler
|
| Mapred_sort | |
| Mapred_sorters |
Sorter classes
|
| Mapred_split |
Splits a line into key and value.
|
| Mapred_stats | |
| Mapred_streaming |
Support for streaming
|
| Mapred_task_exec |
Executes this task
|
| Mapred_task_server |
Factory for the processor "mapred_task_server"
|
| Mapred_taskfiles |
Copy files to and from the task nodes
|
| Mapred_tasks |
Representation of tasks
|
| Mapred_toolkit |
Map/reduce toolkit
|
N | |
| Netplex_shm_manager [Plasma_shm] | |
| Nn_alloc_balanced |
Block allocation algorithm
|
| Nn_alloc_trivial |
Block allocation algorithm
|
| Nn_alloc_types | |
| Nn_authticket |
Management of authentication tickets
|
| Nn_blocklist |
Support module for blocklists
|
| Nn_blockmap |
Already allocated blocks of this inode.
|
| Nn_blockmap_box |
Fast RPC to the blockmap server via camlboxes
|
| Nn_commit |
Two-phase commit protocol
|
| Nn_commit_monitor |
This monitor ensures that only certain commits can be done in parallel.
|
| Nn_config |
Configuration of name nodes
|
| Nn_coord |
The implementation of the namenode component for the coordinator
node
|
| Nn_datanode_ctrl |
Manage tickets and push ticket secrets to the datanodes
|
| Nn_datastore_news |
Getting news about datastores and their availability
|
| Nn_datastores |
Datastore types
|
| Nn_db |
Namenode access routines to database
|
| Nn_dentrycache |
The dentrycache checks whether directory metadata is still up to date.
|
| Nn_elect |
Election of the coordinator
|
| Nn_inodecache |
The inodecache checks whether inode metadata is still up to date.
|
| Nn_manager |
Returns this as factory for inclusion into
Netplex_main.startup
|
| Nn_monitor |
Management of datastores, i.e.
|
| Nn_push |
Push updates to the slaves (client)
|
| Nn_slave |
The implementation of the namenode component for slave nodes
|
| Nn_state |
State manager: Provide the logical view of the state, and forward changes
to the database and to the nameslaves (2-phase commit)
|
| Nn_ug |
Users and groups
|
O | |
| Ord [Mapred_tasks] | |
P | |
| Pfs_auth |
Authentication in server context
|
| Pfs_client | |
| Pfs_condition |
Condition variables
|
| Pfs_datanode | |
| Pfs_db |
Utility functions for database accesses
|
| Pfs_dn_internal | |
| Pfs_nfs3 | |
| Pfs_nn_coord | |
| Pfs_nn_dnadmin | |
| Pfs_nn_fsys | |
| Pfs_nn_internal | |
| Pfs_pmanage |
Manager for potentially persisting objects
|
| Pfs_server | |
| Pfs_types | |
| Pkv_api |
Plasma Key Value API
|
| Pkv_xdr_aux | |
| Place [Mapred_toolkit] | |
| Plasma_blocks |
Helpers for analyzing blocklists
|
| Plasma_client |
Client access to the Plasma Filesystem
|
| Plasma_client_config |
Configuration of clients
|
| Plasma_filebuf |
Buffer for
read and write
|
| Plasma_inodecache |
The inodecache stores the metadata found in inodes, namely the
inodeinfo struct, and subsets of the block list.
|
| Plasma_license | |
| Plasma_netfs |
Accessing PlasmaFS via the
Netfs.stream_fs interface
|
| Plasma_opendir | |
| Plasma_platform |
Some C functions
|
| Plasma_quickstart | |
| Plasma_release | |
| Plasma_release_0_1 | |
| Plasma_release_0_2 | |
| Plasma_release_0_3 | |
| Plasma_release_0_4 | |
| Plasma_release_0_5 | |
| Plasma_rng |
Random numbers
|
| Plasma_shm |
Management of large buffers incl.
|
| Plasma_ug |
Users and groups
|
| Plasmafs_and_hdfs | |
| Plasmafs_authentication | |
| Plasmafs_deployment | |
| Plasmafs_dn_admin | |
| Plasmafs_dn_discovery | |
| Plasmafs_nfs | |
| Plasmafs_nn_admin | |
| Plasmafs_protocol | |
| Plasmafs_start | |
| Plasmakv_intro | |
| Plasmamr_and_hadoop | |
| Plasmamr_file_formats | |
| Plasmamr_howto | |
| Plasmamr_start | |
| Plasmamr_task_types | |
| Plasmamr_toolkit | |
| Platform |
Platform-specific functions
|
| Pmr_task | |
S | |
| Seq [Mapred_toolkit] | |
| Sess_deploy | |
| Sess_mr_cardgames | |
| Sess_mr_wordfreq | |
| Sess_plasma_install | |
| Sess_postgresql_conf | |
| Store [Mapred_toolkit] | |
| StrMap [Plasma_blocks] | |
| String_asc [Mapred_sorters] | |
| String_desc [Mapred_sorters] |
