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