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