class DruidDB::Configuration

Constants

CLIENT_ID
DISCOVERY_PATH
INDEX_SERVICE
KAFKA_BROKER_PATH
KAFKA_OVERFLOW_WAIT
LOG_LEVEL
ROLLUP_GRANULARITY
STRONG_DELETE
TUNING_GRANULARITY
TUNING_WINDOW
WAIT_TIME
ZOOKEEPER

Attributes

client_id[R]
discovery_path[R]
index_service[R]
kafka_broker_path[R]
kafka_overflow_wait[R]
log_level[R]
rollup_granularity[R]
strong_delete[R]
tuning_granularity[R]
tuning_window[R]
wait_time[R]
zookeeper[R]

Public Class Methods

new(opts = {}) click to toggle source
# File lib/druiddb/configuration.rb, line 29
def initialize(opts = {})
  @client_id = opts[:client_id] || CLIENT_ID
  @discovery_path = opts[:discovery_path] || DISCOVERY_PATH
  @index_service = opts[:index_service] || INDEX_SERVICE
  @kafka_broker_path = opts[:kafka_broker_path] || KAFKA_BROKER_PATH
  @kafka_overflow_wait = opts[:kafka_overflow_wait] || KAFKA_OVERFLOW_WAIT
  @log_level = opts[:log_level] || LOG_LEVEL
  @rollup_granularity = rollup_granularity_string(opts[:rollup_granularity])
  @strong_delete = opts[:strong_delete] || STRONG_DELETE
  @tuning_granularity = tuning_granularity_string(opts[:tuning_granularity])
  @tuning_window = opts[:tuning_window] || TUNING_WINDOW
  @wait_time = opts[:wait_time] || WAIT_TIME
  @zookeeper = opts[:zookeeper] || ZOOKEEPER
end

Private Instance Methods

rollup_granularity_string(input) click to toggle source
# File lib/druiddb/configuration.rb, line 46
def rollup_granularity_string(input)
  output_string = input || ROLLUP_GRANULARITY
  output_string.to_s.upcase.freeze
end
tuning_granularity_string(input) click to toggle source
# File lib/druiddb/configuration.rb, line 51
def tuning_granularity_string(input)
  output_string = input || TUNING_GRANULARITY
  output_string.to_s.upcase.freeze
end