Sha256: b486edb153533593e8bcabb35deac1dbf06429abef0e027bcc10dcd91f20d5a0

Contents?: true

Size: 545 Bytes

Versions: 4

Compression:

Stored size: 545 Bytes

Contents

module Embulk
  module Input
    class Presto < InputPlugin
      class ExplainParser
        def self.parse(explain_result)
          explain_text = explain_result.flatten.last.lines.first
          column_name_raw, column_type_raw = explain_text.split(' => ')
          names = column_name_raw.split('[').last.split(']').first.split(',').map{ |name| name.strip }
          types = column_type_raw.split('[').last.split(']').first.split(',').map{ |info| info.split(':').last }
          names.zip(types)
        end
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
embulk-input-presto-0.2.4 lib/embulk/input/presto/explain_parser.rb
embulk-input-presto-0.2.3 lib/embulk/input/presto/explain_parser.rb
embulk-input-presto-0.2.2 lib/embulk/input/presto/explain_parser.rb
embulk-input-presto-0.2.1 lib/embulk/input/presto/explain_parser.rb