class Aq::AqCmd
Public Instance Methods
head(table)
click to toggle source
# File lib/aq/command.rb, line 25 def head(table) query = QueryBuilder.head table, options[:max_rows] Aq::Query.new(options[:bucket], options[:object_prefix]).run(query) end
load(table, source, schema)
click to toggle source
# File lib/aq/command.rb, line 39 def load(table, source, schema) schema = SchemaLoader.new.load schema query = QueryBuilder.load table, source, schema, options[:source_format], options[:partitioning] Aq::Query.new(options[:bucket], options[:object_prefix]).run(query) end
ls(database=nil)
click to toggle source
# File lib/aq/command.rb, line 18 def ls(database=nil) query = QueryBuilder.ls database Aq::Query.new(options[:bucket], options[:object_prefix]).run(query) end
mk(name)
click to toggle source
# File lib/aq/command.rb, line 31 def mk(name) query = QueryBuilder.mk name Aq::Query.new(options[:bucket], options[:object_prefix]).run(query) end
query(query)
click to toggle source
# File lib/aq/command.rb, line 64 def query(query) Aq::Query.new(options[:bucket], options[:object_prefix]).run(query, options[:timeout]) end
rm(name)
click to toggle source
# File lib/aq/command.rb, line 47 def rm(name) if options[:force] answer = true else answer = agree("Would you remove #{name}? (y)es or (n)o") end unless answer puts 'Canceled' exit 1 end query = QueryBuilder.rm name Aq::Query.new(options[:bucket], options[:object_prefix]).run(query) end
version()
click to toggle source
# File lib/aq/command.rb, line 69 def version puts "aq v#{Aq::VERSION}" end