| 1 | const Streamz = require('streamz');
|
| 2 |
|
| 3 | module.exports = {
|
| 4 | collect : require('./collect'),
|
| 5 | timeout : require('./timeout'),
|
| 6 | cut : require('./cut'),
|
| 7 | file : require('./file'),
|
| 8 | fixed : require('./fixed'),
|
| 9 | csv_parser : require('./csv_parser'),
|
| 10 | csv: require('./csv_parser'),
|
| 11 | split : require('./split'),
|
| 12 | expand : require('./expand'),
|
| 13 | stringify : require('./stringify'),
|
| 14 | inspect : require('./inspect'),
|
| 15 | mongo : require('./mongo'),
|
| 16 | mysql : require('./mysql'),
|
| 17 | postgres : require('./postgres'),
|
| 18 | elastic : require('./elasticsearch'),
|
| 19 | cluster : require('./cluster'),
|
| 20 | chain : require('./chain'),
|
| 21 | toStream : require('./tostream'),
|
| 22 | toFile : require('./toFile'),
|
| 23 | map : Streamz,
|
| 24 | keepOpen: require('./keepOpen'),
|
| 25 | prescan: require('./prescan'),
|
| 26 | bigquery: require('./bigquery'),
|
| 27 | streamz : Streamz
|
| 28 | };
|