Class: Embulk::TextGuessPlugin

Inherits:
GuessPlugin show all
Defined in:
lib/embulk/guess_plugin.rb

Direct Known Subclasses

GuessNewline

Instance Method Summary collapse

Methods inherited from GuessPlugin

from_java_object, java_object

Instance Method Details

#guess(config, sample) ⇒ Object 



52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
 
# File 'lib/embulk/guess_plugin.rb', line 52

def guess(config, sample)
  # TODO pure-ruby LineDecoder implementation?
  begin
    task = config.load_config(Java::LineDecoder::DecoderTask)
  rescue
    # TODO log?
    p $!
    p $!.backtrace
    return DataSource.new
  end

  decoder = Java::LineDecoder.new(Java::ListFileInput.new([[sample.java_object]]), task)
  sample_text = ''
  while decoder.nextFile
    first = true
    while line = decoder.poll
      if first
        first = false
      else
        sample_text << task.getNewline().getString()
      end
      sample_text << line
    end
  end

  return guess_text(config, sample_text);
end

#guess_text(config, sample_text) ⇒ Object

Raises:

  • (NotImplementedError) 


80
81
82
 
# File 'lib/embulk/guess_plugin.rb', line 80

def guess_text(config, sample_text)
  raise NotImplementedError, "TextGuessPlugin#guess_text(config, sample_text) must be implemented"
end