class SimpleMapReduce::Server::Config
Constants
- DEFAULT_S3_CONFIG
- DEFAULT_S3_INPUT_BUCKET_NAME
- DEFAULT_S3_INTERMEDIATE_BUCKET_NAME
- DEFAULT_S3_OUTPUT_BUCKET_NAME
- DEFAULT_SERVER_PORT
Attributes
job_tracker_url[R]
job_worker_url[R]
logger[R]
s3_config[R]
s3_input_bucket_name[R]
s3_intermediate_bucket_name[R]
s3_output_bucket_name[R]
server_port[R]
Public Class Methods
new(options)
click to toggle source
# File lib/simple_map_reduce/server/confg.rb, line 21 def initialize(options) setup_s3_config(options) @s3_input_bucket_name = options[:s3_input_bucket_name] || DEFAULT_S3_INPUT_BUCKET_NAME @s3_intermediate_bucket_name = options[:s3_intermediate_bucket_name] || DEFAULT_S3_INTERMEDIATE_BUCKET_NAME @s3_output_bucket_name = options[:s3_output_bucket_name] || DEFAULT_S3_OUTPUT_BUCKET_NAME @server_port = options[:server_port] || 4567 @job_tracker_url = options[:job_tracker_url] @job_worker_url = options[:job_worker_url] @logger = options[:logger] || Logger.new($stdout) end
Private Instance Methods
setup_s3_config(options)
click to toggle source
# File lib/simple_map_reduce/server/confg.rb, line 36 def setup_s3_config(options) s3_config = Hash[options[:s3_config].to_a.map { |v| [v[0].to_sym, v[1]] }] # support ruby <= 2.4 @s3_config = s3_config.empty? ? DEFAULT_S3_CONFIG : s3_config end