Class: Embulk::EmbulkRunner

Inherits:
Object
  • Object
show all
Defined in:
lib/embulk/runner.rb

Instance Method Summary collapse

Constructor Details

#initialize(runner_java) ⇒ EmbulkRunner

Returns a new instance of EmbulkRunner.



4
5
6
 
# File 'lib/embulk/runner.rb', line 4

def initialize(runner_java)
  @runner_java = runner_java  # Java::org.embulk.EmbulkRunner
end

Instance Method Details

#guess(config, options = {}) ⇒ Object 



8
9
10
11
12
13
14
15
16
17
18
19
20
 
# 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 = {}) ⇒ Object 



22
23
24
25
26
27
28
29
30
31
32
33
 
# 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 = {}) ⇒ Object 



35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
 
# 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