class Embulk::EmbulkRunner
Public Class Methods
new(runner_java)
click to toggle source
# File lib/embulk/runner.rb, line 4 def initialize(runner_java) @runner_java = runner_java # Java::org.embulk.EmbulkRunner end
Public Instance Methods
guess(config, options={})
click to toggle source
# File lib/embulk/runner.rb, line 8 def guess(config, options={}) output_path = (options[:next_config_output_path] ? Java::java.lang.String.new(options[:next_config_output_path]) : nil) case config when String @runner_java.guess(Java::java.lang.String.new(config), output_path) when Hash, DataSource @runner_java.guess(DataSource.new(config).to_java, output_path) end nil end
preview(config, options={})
click to toggle source
# File lib/embulk/runner.rb, line 22 def preview(config, options={}) format = (options[:format] ? Java::java.lang.String.new(options[:format]) : nil) case config when String @runner_java.preview(Java::java.lang.String.new(config), format) when Hash, DataSource @runner_java.preview(DataSource.new(config).to_java, format) end nil end
run(config, options={})
click to toggle source
# File lib/embulk/runner.rb, line 35 def run(config, options={}) config_diff_path = (options[:next_config_diff_path] ? Java::java.lang.String.new(options[:next_config_diff_path]) : nil) output_path = # deprecated (options[:next_config_output_path] ? Java::java.lang.String.new(options[:next_config_output_path]) : nil) resume_state_path = (options[:resume_state_path] ? Java::java.lang.String.new(options[:resume_state_path]) : nil) case config when String @runner_java.run(Java::java.lang.String.new(config), config_diff_path, output_path, resume_state_path) when Hash, DataSource @runner_java.run(DataSource.new(config).to_java, config_diff_path, output_path, resume_state_path) end nil end