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