Added to_branch loader

[norberttech]

Change Log

Added

• BranchingLoader

Fixed

Changed

Removed

Deprecated

Security

---

Description

[github-actions]

Flow PHP - Benchmarks

^{_{Results of the benchmarks from this PR are compared with the results from 1.x branch.}}

Extractors

+-----------------------+-------------------+------+-----+------------------+------------------+------------------+
| benchmark             | subject           | revs | its | mem_peak         | mode             | rstdev           |
+-----------------------+-------------------+------+-----+------------------+------------------+------------------+
| AvroExtractorBench    | bench_extract_10k | 1    | 3   | 35.258mb +0.00%  | 817.397ms +0.98% | ±0.20% -74.51%   |
| CSVExtractorBench     | bench_extract_10k | 1    | 3   | 4.975mb +0.03%   | 341.794ms +0.95% | ±0.83% +81.40%   |
| JsonExtractorBench    | bench_extract_10k | 1    | 3   | 5.127mb +0.03%   | 1.036s -0.01%    | ±2.87% +1408.78% |
| ParquetExtractorBench | bench_extract_10k | 1    | 3   | 239.826mb +0.00% | 1.253s +1.30%    | ±0.47% -42.65%   |
| TextExtractorBench    | bench_extract_10k | 1    | 3   | 4.896mb +0.03%   | 35.065ms -0.29%  | ±2.49% +83.48%   |
| XmlExtractorBench     | bench_extract_10k | 1    | 3   | 4.898mb +0.03%   | 435.197ms +1.06% | ±0.20% -68.26%   |
+-----------------------+-------------------+------+-----+------------------+------------------+------------------+

Transformers

+-----------------------------+--------------------------+------+-----+------------------+-----------------+----------------+
| benchmark                   | subject                  | revs | its | mem_peak         | mode            | rstdev         |
+-----------------------------+--------------------------+------+-----+------------------+-----------------+----------------+
| RenameEntryTransformerBench | bench_transform_10k_rows | 1    | 3   | 110.598mb +0.00% | 65.244ms +0.31% | ±0.40% -81.14% |
+-----------------------------+--------------------------+------+-----+------------------+-----------------+----------------+

Loaders

+--------------------+----------------+------+-----+------------------+------------------+-----------------+
| benchmark          | subject        | revs | its | mem_peak         | mode             | rstdev          |
+--------------------+----------------+------+-----+------------------+------------------+-----------------+
| AvroLoaderBench    | bench_load_10k | 1    | 3   | 95.638mb +0.00%  | 469.610ms +1.46% | ±0.86% +89.80%  |
| CSVLoaderBench     | bench_load_10k | 1    | 3   | 54.112mb +0.00%  | 74.564ms +3.29%  | ±1.50% +810.73% |
| JsonLoaderBench    | bench_load_10k | 1    | 3   | 106.543mb +0.00% | 52.896ms +1.30%  | ±0.73% +33.66%  |
| ParquetLoaderBench | bench_load_10k | 1    | 3   | 321.748mb +0.00% | 1.490s +1.65%    | ±0.54% -0.89%   |
| TextLoaderBench    | bench_load_10k | 1    | 3   | 17.936mb +0.01%  | 41.139ms +3.41%  | ±0.20% -19.91%  |
+--------------------+----------------+------+-----+------------------+------------------+-----------------+

Building Blocks

+-------------------------+----------------------------+------+-----+------------------+------------------+------------------+
| benchmark               | subject                    | revs | its | mem_peak         | mode             | rstdev           |
+-------------------------+----------------------------+------+-----+------------------+------------------+------------------+
| RowsBench               | bench_chunk_10_on_10k      | 2    | 3   | 76.673mb +0.00%  | 3.544ms +7.22%   | ±1.38% -38.42%   |
| RowsBench               | bench_diff_left_1k_on_10k  | 2    | 3   | 96.400mb +0.00%  | 182.192ms -1.21% | ±0.61% -43.56%   |
| RowsBench               | bench_diff_right_1k_on_10k | 2    | 3   | 74.925mb +0.00%  | 18.249ms -0.74%  | ±0.83% +132.74%  |
| RowsBench               | bench_drop_1k_on_10k       | 2    | 3   | 77.913mb +0.00%  | 1.936ms +18.10%  | ±2.20% +51.77%   |
| RowsBench               | bench_drop_right_1k_on_10k | 2    | 3   | 77.913mb +0.00%  | 1.916ms +16.31%  | ±2.13% +247.54%  |
| RowsBench               | bench_entries_on_10k       | 2    | 3   | 75.025mb +0.00%  | 2.881ms +17.40%  | ±2.09% +156.20%  |
| RowsBench               | bench_filter_on_10k        | 2    | 3   | 75.554mb +0.00%  | 15.338ms -10.21% | ±0.62% -79.17%   |
| RowsBench               | bench_find_on_10k          | 2    | 3   | 75.554mb +0.00%  | 15.146ms -11.04% | ±1.13% -37.09%   |
| RowsBench               | bench_find_one_on_10k      | 10   | 3   | 73.458mb +0.00%  | 1.906μs +12.52%  | ±2.44% -13.79%   |
| RowsBench               | bench_first_on_10k         | 10   | 3   | 73.458mb +0.00%  | 0.400μs 0.00%    | ±0.00% 0.00%     |
| RowsBench               | bench_flat_map_on_1k       | 2    | 3   | 87.012mb +0.00%  | 13.568ms +4.44%  | ±3.42% +70.96%   |
| RowsBench               | bench_map_on_10k           | 2    | 3   | 116.373mb +0.00% | 66.304ms +1.68%  | ±0.75% +17.23%   |
| RowsBench               | bench_merge_1k_on_10k      | 2    | 3   | 76.074mb +0.00%  | 1.345ms +12.54%  | ±0.61% +77.59%   |
| RowsBench               | bench_partition_by_on_10k  | 2    | 3   | 79.420mb +0.00%  | 57.324ms -1.49%  | ±0.43% -55.86%   |
| RowsBench               | bench_remove_on_10k        | 2    | 3   | 78.175mb +0.00%  | 3.930ms +4.37%   | ±2.26% +1831.00% |
| RowsBench               | bench_sort_asc_on_1k       | 2    | 3   | 73.536mb +0.00%  | 40.176ms -0.70%  | ±0.40% -58.71%   |
| RowsBench               | bench_sort_by_on_1k        | 2    | 3   | 73.537mb +0.00%  | 39.914ms -1.35%  | ±0.50% +11.10%   |
| RowsBench               | bench_sort_desc_on_1k      | 2    | 3   | 73.536mb +0.00%  | 40.404ms -2.23%  | ±0.95% -35.21%   |
| RowsBench               | bench_sort_entries_on_1k   | 2    | 3   | 75.899mb +0.00%  | 7.473ms +1.24%   | ±0.51% -20.21%   |
| RowsBench               | bench_sort_on_1k           | 2    | 3   | 73.458mb +0.00%  | 29.807ms +1.83%  | ±0.17% -70.09%   |
| RowsBench               | bench_take_1k_on_10k       | 10   | 3   | 73.458mb +0.00%  | 13.779μs +3.77%  | ±0.90% -3.61%    |
| RowsBench               | bench_take_right_1k_on_10k | 10   | 3   | 73.458mb +0.00%  | 16.985μs +8.79%  | ±3.53% +485.86%  |
| RowsBench               | bench_unique_on_1k         | 2    | 3   | 96.401mb +0.00%  | 186.868ms -2.67% | ±0.71% +798.22%  |
| NativeEntryFactoryBench | bench_entry_factory        | 1    | 3   | 116.704mb +0.00% | 492.994ms +0.31% | ±1.37% +83.24%   |
| NativeEntryFactoryBench | bench_entry_factory        | 1    | 3   | 60.183mb +0.00%  | 250.102ms +2.75% | ±2.43% +154.48%  |
| NativeEntryFactoryBench | bench_entry_factory        | 1    | 3   | 15.116mb +0.01%  | 52.582ms +0.56%  | ±0.95% -51.97%   |
| TypeDetectorBench       | bench_type_detector        | 1    | 3   | 59.955mb +0.00%  | 435.421ms +2.31% | ±1.34% +591.49%  |
| TypeDetectorBench       | bench_type_detector        | 1    | 3   | 14.494mb +0.01%  | 86.810ms +1.31%  | ±0.81% -22.59%   |
+-------------------------+----------------------------+------+-----+------------------+------------------+------------------+