Read from various data sources.
Shape and optimize for your needs.
Store and secure in one of many available data sinks.
Schema inferring is a process of generating a schema from a whole or part of the dataset.
Once schema is inferred, it can be saved and used to speed up next dataset processing.
All Extractors will try to auto-detect schema however, providing schema explicitly is always a good practice since it can significantly speed up an extraction process by avoiding expensive schema detection.
<?php
declare(strict_types=1);
use function Flow\ETL\Adapter\CSV\from_csv;
use function Flow\ETL\DSL\{data_frame, schema_from_json, schema_to_json, to_stream};
use Flow\ETL\Loader\StreamLoader\Output;
require __DIR__ . '/../../../autoload.php';
if (!\file_exists(__DIR__ . '/output/schema.json')) {
$schema = data_frame()
->read(from_csv(__DIR__ . '/input/dataset.csv'))
->limit(100) // Limiting the number of rows to read will speed up the process but might bring less accurate results
->autoCast()
->schema();
\file_put_contents(__DIR__ . '/output/schema.json', schema_to_json($schema));
} else {
/* @phpstan-ignore-next-line */
$schema = schema_from_json(\file_get_contents(__DIR__ . '/output/schema.json'));
}
// Reading schemaless data formats with predefined schema can significantly improve performance
data_frame()
->read(from_csv(__DIR__ . '/input/dataset.csv', schema: $schema))
->collect()
->write(to_stream(__DIR__ . '/output.txt', truncate: false, output: Output::rows_and_schema))
->run();
+-------+-----------------+------------------------------+--------------------------------+-------------------------------+----------------------------------------------+---------+----------------------------------+---------------------+
| Index | Organization Id | Name | Website | Country | Description | Founded | Industry | Number of employees |
+-------+-----------------+------------------------------+--------------------------------+-------------------------------+----------------------------------------------+---------+----------------------------------+---------------------+
| 1 | 8cC6B5992C0309c | Acevedo LLC | https://www.donovan.com/ | Holy See (Vatican City State) | Multi-channeled bottom-line core | 2019 | Graphic Design / Web Design | 7070 |
| 2 | ec094061FeaF7Bc | Walls-Mcdonald | http://arias-willis.net/ | Lithuania | Compatible encompassing groupware | 2005 | Utilities | 8156 |
| 3 | DAcC5dbc58946A7 | Gregory PLC | http://www.lynch-hoover.net/ | Tokelau | Multi-channeled intangible help-desk | 2019 | Leisure / Travel | 6121 |
| 4 | 8Dd7beDa37FbeD0 | Byrd, Patterson and Knox | https://www.james-velez.net/ | Netherlands | Pre-emptive national function | 1982 | Furniture | 3494 |
| 5 | a3b5c54AEC163e4 | Mcdowell-Hopkins | http://fuentes.com/ | Mayotte | Cloned bifurcated solution | 2016 | Online Publishing | 36 |
| 6 | fDfEBeFDaEb59Af | Hayden and Sons | https://www.shaw-mooney.info/ | Belize | Persistent mobile task-force | 1978 | Insurance | 7010 |
| 7 | 752ef90Eae1f7f5 | Castro LLC | http://wilkinson.com/ | Jamaica | Advanced value-added definition | 2008 | Outsourcing / Offshoring | 2526 |
| 8 | B1D4c5CA34f9992 | Barajas, Baird and Shaw | http://www.jordan-harvey.com/ | United States of America | Stand-alone bandwidth-monitored algorithm | 2000 | Wholesale | 4478 |
| 9 | Cfa1a44106faD4B | Lucas, Galloway and Benjamin | http://silva.info/ | Western Sahara | Persevering leadingedge ability | 1990 | Retail Industry | 8223 |
| 10 | C08fcf292AB17DF | Barker, Hubbard and Bennett | http://www.allen.biz/ | Mauritania | Decentralized fault-tolerant functionalities | 2014 | Museums / Institutions | 7716 |
| 11 | 94B9bEedc626820 | Underwood-Mitchell | https://www.leonard.com/ | Italy | Compatible dynamic support | 1992 | Fine Art | 4564 |
| 12 | FE42dEd40f5DfD8 | Lester, Ochoa and Franco | http://www.munoz.com/ | Timor-Leste | Vision-oriented dynamic conglomeration | 2014 | Motion Pictures / Film | 8075 |
| 13 | 1F861fAbeDdCFea | Arias, Jackson and Hester | https://hardin-thompson.com/ | Algeria | Switchable maximized synergy | 1980 | Utilities | 1319 |
| 14 | 456de7dE1ab18ca | Riggs and Sons | http://klein-benton.info/ | Czech Republic | Object-based discrete orchestration | 2012 | Law Enforcement | 4946 |
| 15 | 457bcfFF18A7DD2 | Stanley LLC | https://bowman.com/ | Eritrea | Self-enabling 24/7 groupware | 1984 | Executive Office | 4980 |
| 16 | 5B5ea5aea34dc5F | Page-Ware | http://lam-soto.com/ | Togo | Realigned mobile groupware | 1991 | Entertainment / Movie Production | 1307 |
| 17 | A66F35C298Dfd82 | Garner, Melton and Burgess | https://mathews-knox.com/ | Guinea-Bissau | Automated 5thgeneration complexity | 2003 | E - Learning | 9038 |
| 18 | EdAC2EF13734E0B | Andersen-Fuentes | http://www.mann.com/ | Oman | Ameliorated coherent database | 1991 | Textiles | 6436 |
| 19 | dD1612190b24B12 | Ford-Rice | https://peterson-irwin.com/ | Turks and Caicos Islands | Sharable intangible leverage | 1971 | Computer / Network Security | 3038 |
| 20 | 992CAdffccEebEa | Collins-Figueroa | http://www.holt-bartlett.info/ | Mongolia | Realigned multi-state installation | 1985 | Aviation / Aerospace | 9420 |
+-------+-----------------+------------------------------+--------------------------------+-------------------------------+----------------------------------------------+---------+----------------------------------+---------------------+
20 rows
schema
|-- Index: integer
|-- Organization Id: string
|-- Name: string
|-- Website: string
|-- Country: string
|-- Description: string
|-- Founded: integer
|-- Industry: string
|-- Number of employees: integer
