Class: Bricolage::MySQLTask

Inherits:
DataSourceTask
  • Object
show all
Defined in:
lib/bricolage/mysqldatasource.rb

Defined Under Namespace

Classes: CSVWriter, Export, JSONWriter, S3Export, TSVWriter

Constant Summary collapse

WRITER_CLASSES = 
{}

Instance Method Summary collapse

Instance Method Details

#export(stmt, path: nil, format: nil, override: false, gzip: false, sqldump: false) ⇒ Object 



71
72
73
 
# File 'lib/bricolage/mysqldatasource.rb', line 71

def export(stmt, path: nil, format: nil, override: false, gzip: false, sqldump: false)
  add Export.new(stmt, path: path, format: format, override: override, gzip: gzip, sqldump: sqldump)
end

#s3export(table, stmt, s3ds, prefix, gzip, dump_options) ⇒ Object 



176
177
178
179
180
181
182
183
184
185
186
187
188
 
# File 'lib/bricolage/mysqldatasource.rb', line 176

def s3export(table, stmt, s3ds, prefix, gzip, dump_options)
  options = dump_options.nil? ? {} : dump_options[:dump_options]
  add S3Export.new(table, stmt, s3ds, prefix, gzip: gzip,
    format: options['format'],
    partition_column: options['partition_column'],
    partition_number: options['partition_number'],
    write_concurrency: options['write_concurrency'],
    rotation_size: options['rotation_size'],
    delete_objects: options['delete_objects'],
    object_key_delimiter: options['object_key_delimiter'],
    src_zone_offset: options['src_zone_offset'],
    dst_zone_offset: options['dst_zone_offset'])
end