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