Skip to content

feat(flow-php/etl): schema-driven Floe writes with validation option#2540

Merged
norberttech merged 1 commit into
1.xfrom
performance-optimization
Jul 19, 2026
Merged

feat(flow-php/etl): schema-driven Floe writes with validation option#2540
norberttech merged 1 commit into
1.xfrom
performance-optimization

Conversation

@norberttech

@norberttech norberttech commented Jul 19, 2026

Copy link
Copy Markdown
Member

Change Log


Added

  • flow-php/etl - Floe Options value object with validateData toggle
  • flow-php/etl - floe_options() DSL and options argument on to_floe()

Fixed

Changed

  • flow-php/etl - FloeWriter/FloeStreamWriter take schema in constructor and build encoder once
  • flow-php/etl - external-sort and hash-join spill cache skip per-write schema validation
  • flow-php/etl - fast-path identity and count checks in array and metadata equality

Removed

Deprecated

Security

  +-----------------------------+-----------+-----------+---------+-----------+                                                                                                                                                                                                                               
  | subject                     | before    | after     | delta   | mem_peak  |                                                                                                                                                                                                                               
  +-----------------------------+-----------+-----------+---------+-----------+                                                                                                                                                                                                                               
  | join_left                   | 4.413s    | 2.721s    | -38.35% | ~0.00%    |                                                                                                                                                                                                                               
  | join_inner                  | 4.377s    | 2.721s    | -37.82% | ~0.00%    |                                                                                                                                                                                                                               
  | join_left_anti              | 3.882s    | 2.262s    | -41.72% | ~0.00%    |                                                                                                                                                                                                                               
  | join_right                  | 4.613s    | 2.809s    | -39.12% | ~0.00%    |                                                                                                                                                                                                                               
  | cross_join                  | 1.261s    | 1.139s    |  -9.68% | ~0.00%    |                                                                                                                                                                                                                               
  | join_each                   | 1.711s    | 1.531s    | -10.52% | ~0.00%    |                                                                                                                                                                                                                               
  | sort_orders                 | 4.403s    | 2.424s    | -44.93% | ~0.00%    |                                                                                                                                                                                                                               
  | floe_write (php)            | 4.405s    | 3.637s    | -17.45% | ~0.00%    |                                                                                                                                                                                                                               
  | floe_write (native)         | 2.530s    | 1.859s    | -26.50% | ~0.00%    |                                                                                                                                                                                                                               
  | floe_read (php)             | 1.696s    | 1.549s    |  -8.67% | ~0.00%    |                                                                                                                                                                                                                               
  | floe_read (native)          | 0.636s    | 0.465s    | -26.93% | ~0.00%    |                                                                                                                                                                                                                               
  +-----------------------------+-----------+-----------+---------+-----------+      

View with Codesmith Autofix with Codesmith
Need help on this PR? Tag /codesmith with what you need. Autofix is disabled.

- FloeWriter/FloeStreamWriter take schema in constructor, build encoder
once
- add validateData option to skip per-write schema re-validation
- disable validation on external-sort / hash-join spill cache
- Options value object plus floe_options() and to_floe(options:) DSL
- fast-path identity/count checks in array & metadata equality
@codecov

codecov Bot commented Jul 19, 2026

Copy link
Copy Markdown

Codecov Report

❌ Patch coverage is 93.97590% with 5 lines in your changes missing coverage. Please review.
✅ Project coverage is 86.31%. Comparing base (1b82643) to head (711fa3f).
⚠️ Report is 2 commits behind head on 1.x.
✅ All tests successful. No failed tests found.

Additional details and impacted files
@@            Coverage Diff            @@
##                1.x    #2540   +/-   ##
=========================================
  Coverage     86.31%   86.31%           
- Complexity    23220    23233   +13     
=========================================
  Files          1760     1761    +1     
  Lines         70762    70803   +41     
=========================================
+ Hits          61080    61117   +37     
- Misses         9682     9686    +4     
Components Coverage Δ
etl 89.68% <93.97%> (+<0.01%) ⬆️
cli 89.40% <ø> (ø)
lib-array-dot 81.44% <ø> (ø)
lib-azure-sdk 64.44% <ø> (ø)
lib-doctrine-dbal-bulk 93.61% <ø> (ø)
lib-filesystem 86.64% <ø> (ø)
lib-types 91.15% <ø> (ø)
lib-parquet 70.23% <ø> (ø)
lib-parquet-viewer 82.26% <ø> (ø)
lib-snappy 88.93% <ø> (-0.45%) ⬇️
lib-dremel 0.00% <ø> (ø)
lib-postgresql 88.62% <ø> (ø)
lib-telemetry 86.58% <ø> (ø)
bridge-filesystem-async-aws 92.74% <ø> (ø)
bridge-filesystem-azure 90.45% <ø> (ø)
bridge-monolog-http 96.82% <ø> (ø)
bridge-monolog-telemetry 94.79% <ø> (ø)
bridge-openapi-specification 92.07% <ø> (ø)
symfony-http-foundation 78.57% <ø> (ø)
bridge-psr18-telemetry 100.00% <ø> (ø)
bridge-psr3-telemetry 98.95% <ø> (ø)
bridge-psr7-telemetry 100.00% <ø> (ø)
bridge-telemetry-otlp 90.41% <ø> (ø)
bridge-symfony-http-foundation-telemetry 92.85% <ø> (ø)
bridge-symfony-filesystem-bundle 91.85% <ø> (ø)
bridge-symfony-filesystem-cache 98.18% <ø> (ø)
bridge-symfony-postgresql-bundle 93.70% <ø> (ø)
bridge-symfony-postgresql-cache 94.41% <ø> (ø)
bridge-symfony-postgresql-messenger 98.80% <ø> (ø)
bridge-symfony-postgresql-session 93.65% <ø> (ø)
bridge-symfony-telemetry-bundle 90.10% <ø> (ø)
adapter-chartjs 84.05% <ø> (ø)
adapter-csv 89.46% <ø> (ø)
adapter-doctrine 90.75% <ø> (ø)
adapter-google-sheet 91.56% <ø> (ø)
adapter-http 73.23% <ø> (ø)
adapter-json 87.30% <ø> (ø)
adapter-logger 50.00% <ø> (ø)
adapter-parquet 88.69% <ø> (ø)
adapter-text 92.59% <ø> (ø)
adapter-xml 83.56% <ø> (ø)
adapter-avro 0.00% <ø> (ø)
adapter-excel 86.72% <ø> (ø)
adapter-postgresql 90.84% <ø> (ø)
adapter-seal 83.26% <ø> (ø)
bridge-phpunit-postgresql 75.30% <ø> (ø)
bridge-phpunit-telemetry 87.32% <ø> (ø)
bridge-phpstan-types 0.00% <ø> (ø)
bridge-postgresql-valinor 100.00% <ø> (ø)
🚀 New features to boost your workflow:
  • 📦 JS Bundle Analysis: Save yourself from yourself by tracking and limiting bundle sizes in JS merges.

@norberttech
norberttech merged commit 91a9da6 into 1.x Jul 19, 2026
50 checks passed
@norberttech
norberttech deleted the performance-optimization branch July 19, 2026 21:14
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant