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