@@ -38,29 +38,27 @@ Supported PHP versions: [;
4040
41- use Flow\ETL\DSL\Parquet;
41+ use function Flow\ETL\Adapter\Parquet\{from_parquet, to_parquet};
42+ use function Flow\ETL\DSL\{data_frame, lit, ref, sum, to_output};
4243use Flow\ETL\Filesystem\SaveMode;
43- use function Flow\ETL\DSL\{lit, ref, sum};
44- use Flow\ETL\DSL\To;
45- use Flow\ETL\Flow;
4644
4745require __DIR__ . '/vendor/autoload.php';
4846
49- (new Flow() )
50- ->read(Parquet::from (__FLOW_DATA__ . '/orders_flow.parquet'))
47+ data_frame( )
48+ ->read(from_parquet (__FLOW_DATA__ . '/orders_flow.parquet'))
5149 ->select('created_at', 'total_price', 'discount')
52- ->withEntry('created_at', ref('created_at')->toDate(\DateTime::RFC3339 )->dateFormat('Y/m'))
50+ ->withEntry('created_at', ref('created_at')->cast('date' )->dateFormat('Y/m'))
5351 ->withEntry('revenue', ref('total_price')->minus(ref('discount')))
5452 ->select('created_at', 'revenue')
5553 ->groupBy('created_at')
5654 ->aggregate(sum(ref('revenue')))
5755 ->sortBy(ref('created_at')->desc())
5856 ->withEntry('daily_revenue', ref('revenue_sum')->round(lit(2))->numberFormat(lit(2)))
5957 ->drop('revenue_sum')
60- ->write(To::output(truncate: false))
61- ->mode(SaveMode::Overwrite)
58+ ->write(to_output(truncate: false))
6259 ->withEntry('created_at', ref('created_at')->toDate('Y/m'))
63- ->write(Parquet::to(__FLOW_OUTPUT__ . '/daily_revenue.parquet'))
60+ ->mode(SaveMode::Overwrite)
61+ ->write(to_parquet(__FLOW_OUTPUT__ . '/daily_revenue.parquet'))
6462 ->run();
6563```
6664
0 commit comments