Class: Bricolage::MySQLTask
- Inherits:
-
DataSourceTask
- Object
- DataSourceTask
- Bricolage::MySQLTask
- Defined in:
- lib/bricolage/mysqldatasource.rb
Defined Under Namespace
Classes: CSVWriter, Export, JSONWriter, S3Export, TSVWriter
Constant Summary collapse
- WRITER_CLASSES =
{}
Instance Method Summary collapse
- #export(stmt, path: nil, format: nil, override: false, gzip: false, sqldump: false) ⇒ Object
- #s3export(table, stmt, s3ds, prefix, gzip, dump_options) ⇒ Object
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, ) = .nil? ? {} : [:dump_options] add S3Export.new(table, stmt, s3ds, prefix, gzip: gzip, format: ['format'], partition_column: ['partition_column'], partition_number: ['partition_number'], write_concurrency: ['write_concurrency'], rotation_size: ['rotation_size'], delete_objects: ['delete_objects'], object_key_delimiter: ['object_key_delimiter'], src_zone_offset: ['src_zone_offset'], dst_zone_offset: ['dst_zone_offset']) end |