Module: ScbiMapreduce

Defined in:

lib/scbi_mapreduce.rb,
lib/scbi_mapreduce/worker.rb,
lib/scbi_mapreduce/manager.rb,
lib/scbi_mapreduce/work_manager.rb,
lib/scbi_mapreduce/error_handler.rb,
lib/scbi_mapreduce/worker_launcher.rb

Overview

TODO - Make a per-node launcher: launch_workers server_ip server_port count

Defined Under Namespace

Classes: Manager, WorkManager, WorkManagerData, Worker, WorkerError, WorkerLauncher

Constant Summary

VERSION =

'0.0.40'

PENDING_TO_SAVE =

10

CHECKPOINT_FILE =

'scbi_mapreduce_checkpoint'

OLD_CHECKPOINT_FILE =

'old_scbi_mapreduce_checkpoint'

PROCESSING_TIMEOUT_MULTIPLIER =

10

INTERPRETER =

'ruby'