Fixed multiple groupby execution in single pipeline

[norberttech]

Change Log

Added

Fixed

• multiple group by execution in single pipeline
• moved elasticsearch HTTP Spy test double under Test namespace

Changed

• reorganized data frame tests

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   | 34.762mb +0.00%  | 666.440ms +0.05% | ±0.36% -79.37%   |
| CSVExtractorBench     | bench_extract_10k | 1    | 3   | 4.627mb +0.02%   | 295.075ms -0.32% | ±0.57% +1199.92% |
| JsonExtractorBench    | bench_extract_10k | 1    | 3   | 4.786mb +0.02%   | 908.929ms -0.06% | ±0.97% +7.23%    |
| ParquetExtractorBench | bench_extract_10k | 1    | 3   | 239.496mb +0.00% | 1.086s +0.15%    | ±0.71% +129.55%  |
| TextExtractorBench    | bench_extract_10k | 1    | 3   | 4.567mb +0.02%   | 23.816ms +1.36%  | ±2.73% +670.33%  |
| XmlExtractorBench     | bench_extract_10k | 1    | 3   | 4.568mb +0.02%   | 406.379ms -1.69% | ±0.47% -35.58%   |
+-----------------------+-------------------+------+-----+------------------+------------------+------------------+

Transformers

+-----------------------------+--------------------------+------+-----+------------------+-----------------+-----------------+
| benchmark                   | subject                  | revs | its | mem_peak         | mode            | rstdev          |
+-----------------------------+--------------------------+------+-----+------------------+-----------------+-----------------+
| RenameEntryTransformerBench | bench_transform_10k_rows | 1    | 3   | 110.251mb +0.00% | 61.144ms -3.39% | ±1.27% +112.81% |
+-----------------------------+--------------------------+------+-----+------------------+-----------------+-----------------+

Loaders

+--------------------+----------------+------+-----+------------------+------------------+----------------+
| benchmark          | subject        | revs | its | mem_peak         | mode             | rstdev         |
+--------------------+----------------+------+-----+------------------+------------------+----------------+
| AvroLoaderBench    | bench_load_10k | 1    | 3   | 94.423mb +0.00%  | 437.924ms +0.61% | ±0.48% -78.44% |
| CSVLoaderBench     | bench_load_10k | 1    | 3   | 54.733mb +0.00%  | 71.446ms -0.33%  | ±0.24% -73.62% |
| JsonLoaderBench    | bench_load_10k | 1    | 3   | 105.005mb +0.00% | 52.838ms -1.68%  | ±0.62% -0.05%  |
| ParquetLoaderBench | bench_load_10k | 1    | 3   | 320.483mb +0.00% | 1.470s -3.41%    | ±2.40% +4.71%  |
| TextLoaderBench    | bench_load_10k | 1    | 3   | 17.607mb +0.01%  | 40.882ms -2.89%  | ±0.67% +3.54%  |
+--------------------+----------------+------+-----+------------------+------------------+----------------+

Building Blocks

+-------------------------+----------------------------+------+-----+------------------+------------------+-----------------+
| benchmark               | subject                    | revs | its | mem_peak         | mode             | rstdev          |
+-------------------------+----------------------------+------+-----+------------------+------------------+-----------------+
| RowsBench               | bench_chunk_10_on_10k      | 2    | 3   | 76.300mb +0.00%  | 2.646ms +1.41%   | ±2.48% +205.01% |
| RowsBench               | bench_diff_left_1k_on_10k  | 2    | 3   | 96.091mb +0.00%  | 175.945ms -0.94% | ±0.65% +8.69%   |
| RowsBench               | bench_diff_right_1k_on_10k | 2    | 3   | 74.617mb +0.00%  | 17.512ms -1.65%  | ±1.05% +21.25%  |
| RowsBench               | bench_drop_1k_on_10k       | 2    | 3   | 77.540mb +0.00%  | 1.624ms -1.32%   | ±1.74% +0.63%   |
| RowsBench               | bench_drop_right_1k_on_10k | 2    | 3   | 77.540mb +0.00%  | 1.672ms +0.74%   | ±1.66% -33.70%  |
| RowsBench               | bench_entries_on_10k       | 2    | 3   | 74.652mb +0.00%  | 2.512ms -0.22%   | ±1.16% -4.45%   |
| RowsBench               | bench_filter_on_10k        | 2    | 3   | 75.181mb +0.00%  | 15.153ms -12.19% | ±0.51% +4.67%   |
| RowsBench               | bench_find_on_10k          | 2    | 3   | 75.181mb +0.00%  | 14.937ms -13.04% | ±0.89% -54.02%  |
| RowsBench               | bench_find_one_on_10k      | 10   | 3   | 73.084mb +0.00%  | 1.700μs -14.74%  | ±0.00% -100.00% |
| RowsBench               | bench_first_on_10k         | 10   | 3   | 73.084mb +0.00%  | 0.300μs -25.00%  | ±0.00% -100.00% |
| RowsBench               | bench_flat_map_on_1k       | 2    | 3   | 86.641mb +0.00%  | 12.511ms -1.64%  | ±0.67% -69.74%  |
| RowsBench               | bench_map_on_10k           | 2    | 3   | 116.000mb +0.00% | 62.467ms +0.39%  | ±1.03% +445.86% |
| RowsBench               | bench_merge_1k_on_10k      | 2    | 3   | 75.702mb +0.00%  | 1.748ms +1.43%   | ±1.61% -56.12%  |
| RowsBench               | bench_partition_by_on_10k  | 2    | 3   | 77.973mb +0.00%  | 33.228ms -12.88% | ±1.04% +103.41% |
| RowsBench               | bench_remove_on_10k        | 2    | 3   | 77.802mb +0.00%  | 3.833ms -0.66%   | ±2.71% +195.94% |
| RowsBench               | bench_sort_asc_on_1k       | 2    | 3   | 73.227mb +0.00%  | 39.280ms -0.36%  | ±0.85% +12.50%  |
| RowsBench               | bench_sort_by_on_1k        | 2    | 3   | 73.228mb +0.00%  | 38.983ms +0.19%  | ±0.51% -82.53%  |
| RowsBench               | bench_sort_desc_on_1k      | 2    | 3   | 73.227mb +0.00%  | 40.110ms +0.85%  | ±1.39% +141.81% |
| RowsBench               | bench_sort_entries_on_1k   | 2    | 3   | 75.526mb +0.00%  | 7.340ms -0.79%   | ±1.69% +428.83% |
| RowsBench               | bench_sort_on_1k           | 2    | 3   | 73.084mb +0.00%  | 28.463ms -1.90%  | ±0.92% +23.84%  |
| RowsBench               | bench_take_1k_on_10k       | 10   | 3   | 73.084mb +0.00%  | 13.500μs +1.46%  | ±0.60% +71.07%  |
| RowsBench               | bench_take_right_1k_on_10k | 10   | 3   | 73.084mb +0.00%  | 15.683μs -0.24%  | ±1.37% +71.74%  |
| RowsBench               | bench_unique_on_1k         | 2    | 3   | 96.092mb +0.00%  | 180.069ms -0.34% | ±0.49% -42.13%  |
| TypeDetectorBench       | bench_type_detector        | 1    | 3   | 59.172mb +0.00%  | 313.900ms -3.18% | ±0.37% -84.25%  |
| TypeDetectorBench       | bench_type_detector        | 1    | 3   | 14.095mb +0.01%  | 62.737ms -0.99%  | ±1.80% +49.09%  |
| NativeEntryFactoryBench | bench_entry_factory        | 1    | 3   | 115.842mb +0.00% | 362.108ms -0.97% | ±1.69% +30.08%  |
| NativeEntryFactoryBench | bench_entry_factory        | 1    | 3   | 59.561mb +0.00%  | 179.177ms -2.46% | ±0.29% -81.33%  |
| NativeEntryFactoryBench | bench_entry_factory        | 1    | 3   | 14.685mb +0.01%  | 38.931ms +1.26%  | ±1.97% +26.05%  |
+-------------------------+----------------------------+------+-----+------------------+------------------+-----------------+