diff --git a/lib/rbhive/table_schema.rb b/lib/rbhive/table_schema.rb index 23fd1de..7b7d831 100644 --- a/lib/rbhive/table_schema.rb +++ b/lib/rbhive/table_schema.rb @@ -37,7 +37,11 @@ def create_table_statement() end def stored_as - @stored_as.to_s.upcase + if @stored_as.is_a? String + @stored_as.to_s.upcase + else + "INPUTFORMAT '#{@stored_as[:inputformat]}' OUTPUTFORMAT '#{@stored_as[:outputformat]}'" + end end def row_format_statement @@ -119,4 +123,4 @@ def to_s end end end -end \ No newline at end of file +end