class RBHive::ResultSet

Public Class Methods

new(rows, schema) click to toggle source
Calls superclass method
  # File lib/rbhive/result_set.rb
3 def initialize(rows, schema)
4   @schema = schema
5   super(rows.map {|r| @schema.coerce_row(r) })
6 end

Public Instance Methods

as_arrays() click to toggle source
   # File lib/rbhive/result_set.rb
24 def as_arrays
25   @as_arrays ||= self.map{ |r| @schema.coerce_row_to_array(r) }
26 end
column_names() click to toggle source
   # File lib/rbhive/result_set.rb
 8 def column_names
 9   @schema.column_names
10 end
column_type_map() click to toggle source
   # File lib/rbhive/result_set.rb
12 def column_type_map
13   @schema.column_type_map
14 end
to_csv(out_file=nil) click to toggle source
   # File lib/rbhive/result_set.rb
16 def to_csv(out_file=nil)
17   to_separated_output(",", out_file)
18 end
to_tsv(out_file=nil) click to toggle source
   # File lib/rbhive/result_set.rb
20 def to_tsv(out_file=nil)
21   to_separated_output("\t", out_file)
22 end

Private Instance Methods

to_separated_output(sep, out_file) click to toggle source
   # File lib/rbhive/result_set.rb
30 def to_separated_output(sep, out_file)
31   rows = self.map { |r| @schema.coerce_row_to_array(r).join(sep) }
32   sv = rows.join("\n")
33   return sv if out_file.nil?
34   File.open(out_file, 'w+') { |f| f << sv }
35 end