class Dag::Database

Attributes

cluster_name[R]
db_name[R]
name[R]

Public Class Methods

new(api, cluster_name, db_name, cluster_status: nil) click to toggle source
Calls superclass method Dag::Model::new
# File lib/dag/client/model/database.rb, line 3
def initialize(api, cluster_name, db_name, cluster_status: nil)
  super(api)

  @cluster_name = cluster_name
  @cluster_status = cluster_status
  @db_name = db_name
  @name = @db_name
end

Public Instance Methods

delete() click to toggle source
# File lib/dag/client/model/database.rb, line 14
def delete
  @api.delete_database(@cluster_name, @name)
end
split(tbl_name, params) click to toggle source

parameters ==

  • label - label

  • input_object_keys - array of object_keys. ex [“#{bucket}/${big_object1}”, “#{bucket}/${big_object2}”]

  • input_format - 'csv' or 'tsv' or 'json'

  • schema - schema

# File lib/dag/client/model/database.rb, line 24
def split(tbl_name, params)
  split_info = @api.split_table(@cluster_name, @db_name, tbl_name, params)
  job_id = split_info['queryId']

  query_info = @api.query_info(job_id)
  Dag::Job.new(@api, query_info)
end