lib/rspec/hive/connection_delegator.rb in rspec-hive-0.6.2 vs lib/rspec/hive/connection_delegator.rb in rspec-hive-0.6.3
- old
+ new
@@ -79,15 +79,17 @@
"PARTITION(#{partition.map { |k, v| "#{k}=#{partition_value(table_schema, k, v)}" }.join(',')})"
end
def partition_value(table_schema, key, value)
return value if table_schema.partitions.detect { |x| x.name == key && x.type == :int }
+
"'#{value}'"
end
def load_file_to_hive_table(table_name, path, partition_clause = nil)
request_txt = "load data local inpath '#{path}' into table #{table_name}"
return execute(request_txt) if partition_clause.nil?
+
execute("#{request_txt} #{partition_clause}")
end
def docker_path(file)
File.join(