module Wukong::Load
Loads data from the command-line into data stores.
Constants
- VERSION
Public Class Methods
boot(settings, dir)
click to toggle source
Boot Wukong-Load from the resolved `settings` in the given `dir`.
@param [Configliere::Param] settings the resolved settings @param [String] dir the directory to boot in
# File lib/wukong-load.rb, line 30 def self.boot settings, dir end
configure(settings, program)
click to toggle source
Configure `settings` for Wukong-Load.
Will ensure that `wu-load` has the same settings as `wu-local`.
@param [Configliere::Param] settings the settings to configure @param [String] program the currently executing program name
# File lib/wukong-load.rb, line 14 def self.configure settings, program case program when 'wu-load' settings.define :tcp_port, description: "Consume TCP requests on the given port instead of lines over STDIN", type: Integer, flag: 't' when 'wu-source' settings.define :per_sec, description: "Number of events produced per second", type: Float settings.define :period, description: "Number of seconds between events (overrides --per_sec)", type: Float settings.define :batch_size, description: "Trigger a finalize across the dataflow each time this many records are processed", type: Integer end end