Skip to content

Conversation

@norberttech
Copy link
Member

Resolves: #1789

Change Log


Added

  • DataFrame::offset method
  • Support for offset method in Flow CLI

Fixed

Changed

Removed

Deprecated

Security

Added DataFrame::offsetMethod implemented by OffsetPipeline
@norberttech norberttech linked an issue Jul 28, 2025 that may be closed by this pull request
@codecov
Copy link

codecov bot commented Jul 28, 2025

Codecov Report

❌ Patch coverage is 94.82759% with 3 lines in your changes missing coverage. Please review.
✅ Project coverage is 82.25%. Comparing base (ca1e62e) to head (60b8306).
⚠️ Report is 1 commits behind head on 1.x.
✅ All tests successful. No failed tests found.

Additional details and impacted files
@@            Coverage Diff             @@
##              1.x    #1790      +/-   ##
==========================================
+ Coverage   82.20%   82.25%   +0.05%     
==========================================
  Files         750      752       +2     
  Lines       21194    21251      +57     
==========================================
+ Hits        17422    17480      +58     
+ Misses       3772     3771       -1     
Components Coverage Δ
etl 89.09% <94.59%> (+0.05%) ⬆️
cli 85.91% <95.23%> (+0.34%) ⬆️
lib-array-dot 94.56% <ø> (ø)
lib-azure-sdk 61.35% <ø> (ø)
lib-doctrine-dbal-bulk 95.59% <ø> (ø)
lib-filesystem 78.02% <ø> (ø)
lib-types 53.55% <ø> (ø)
lib-parquet 85.50% <ø> (ø)
lib-parquet-viewer 83.11% <ø> (ø)
lib-snappy 90.23% <ø> (+0.46%) ⬆️
bridge-filesystem-async-aws 90.38% <ø> (ø)
bridge-filesystem-azure 89.92% <ø> (ø)
bridge-monolog-http 97.04% <ø> (ø)
bridge-openapi-specification 93.16% <ø> (ø)
symfony-http-foundation 74.41% <ø> (ø)
adapter-chartjs 86.70% <ø> (ø)
adapter-csv 88.85% <ø> (ø)
adapter-doctrine 91.03% <ø> (ø)
adapter-elasticsearch 97.23% <ø> (ø)
adapter-google-sheet 83.87% <ø> (ø)
adapter-http 58.10% <ø> (ø)
adapter-json 87.98% <ø> (ø)
adapter-logger 53.84% <ø> (ø)
adapter-meilisearch 97.95% <ø> (ø)
adapter-parquet 78.92% <ø> (ø)
adapter-text 84.44% <ø> (ø)
adapter-xml 82.73% <ø> (ø)
🚀 New features to boost your workflow:
  • 📦 JS Bundle Analysis: Save yourself from yourself by tracking and limiting bundle sizes in JS merges.

@github-actions
Copy link
Contributor

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         |
+-----------------------+------------------------+------+-----+-----------------+------------------+----------------+
| CSVExtractorBench     | bench_extract_10k      | 1    | 3   | 4.888mb -0.00%  | 448.130ms +2.24% | ±1.04% +49.06% |
| ExcelExtractorBench   | bench_extract_10k_ods  | 1    | 3   | 65.583mb -0.00% | 1.075s -0.14%    | ±0.38% -69.46% |
| ExcelExtractorBench   | bench_extract_10k_xlsx | 1    | 3   | 67.683mb -0.00% | 1.684s -1.06%    | ±0.22% -52.29% |
| JsonExtractorBench    | bench_extract_10k      | 1    | 3   | 5.480mb -0.00%  | 1.140s -0.37%    | ±1.10% +87.76% |
| ParquetExtractorBench | bench_extract_10k      | 1    | 3   | 10.706mb -0.18% | 9.284s -19.79%   | ±0.67% +5.99%  |
| TextExtractorBench    | bench_extract_10k      | 1    | 3   | 4.611mb -0.00%  | 42.009ms -0.24%  | ±0.30% -70.05% |
| XmlExtractorBench     | bench_extract_10k      | 1    | 3   | 4.596mb -0.00%  | 596.385ms -0.85% | ±0.56% -14.74% |
+-----------------------+------------------------+------+-----+-----------------+------------------+----------------+
Transformers
+---------------------------------+--------------------------+------+-----+------------------+-----------------+----------------+
| benchmark                       | subject                  | revs | its | mem_peak         | mode            | rstdev         |
+---------------------------------+--------------------------+------+-----+------------------+-----------------+----------------+
| RenameEachEntryTransformerBench | bench_transform_10k_rows | 1    | 3   | 18.607mb -0.00%  | 73.381ms -3.53% | ±1.63% -27.79% |
| RenameEntryTransformerBench     | bench_transform_10k_rows | 1    | 3   | 123.345mb -0.00% | 68.029ms -1.37% | ±0.34% -70.84% |
+---------------------------------+--------------------------+------+-----+------------------+-----------------+----------------+
Loaders
+--------------------+----------------+------+-----+------------------+------------------+----------------+
| benchmark          | subject        | revs | its | mem_peak         | mode             | rstdev         |
+--------------------+----------------+------+-----+------------------+------------------+----------------+
| CSVLoaderBench     | bench_load_10k | 1    | 3   | 62.549mb -0.00%  | 83.372ms -5.68%  | ±0.61% -70.93% |
| JsonLoaderBench    | bench_load_10k | 1    | 3   | 80.630mb -0.00%  | 100.881ms -4.52% | ±0.71% -74.01% |
| ParquetLoaderBench | bench_load_10k | 1    | 3   | 819.309mb +0.04% | 20.243s -26.42%  | ±0.20% -46.38% |
| TextLoaderBench    | bench_load_10k | 1    | 3   | 17.913mb -0.00%  | 30.009ms -1.60%  | ±0.84% -36.41% |
+--------------------+----------------+------+-----+------------------+------------------+----------------+
Building Blocks
+-------------------+----------------------------+------+-----+------------------+------------------+-----------------+
| benchmark         | subject                    | revs | its | mem_peak         | mode             | rstdev          |
+-------------------+----------------------------+------+-----+------------------+------------------+-----------------+
| EntryFactoryBench | bench_entry_factory        | 1    | 3   | 106.027mb -0.00% | 656.973ms -1.84% | ±0.25% -85.86%  |
| EntryFactoryBench | bench_entry_factory        | 1    | 3   | 55.302mb -0.00%  | 329.703ms -1.52% | ±1.09% -3.61%   |
| EntryFactoryBench | bench_entry_factory        | 1    | 3   | 14.888mb -0.00%  | 70.392ms +0.26%  | ±2.85% +154.63% |
| TypeDetectorBench | bench_type_detector        | 1    | 3   | 42.558mb -0.00%  | 405.019ms -0.45% | ±0.11% -86.37%  |
| TypeDetectorBench | bench_type_detector        | 1    | 3   | 11.615mb -0.00%  | 81.331ms -0.70%  | ±0.51% +33.35%  |
| RowsBench         | bench_chunk_10_on_10k      | 2    | 3   | 93.498mb -0.00%  | 3.337ms -14.43%  | ±0.88% -70.43%  |
| RowsBench         | bench_diff_left_1k_on_10k  | 2    | 3   | 110.888mb -0.00% | 237.271ms -2.51% | ±0.58% -51.77%  |
| RowsBench         | bench_diff_right_1k_on_10k | 2    | 3   | 93.608mb -0.00%  | 24.064ms -0.46%  | ±0.93% -52.54%  |
| RowsBench         | bench_drop_1k_on_10k       | 2    | 3   | 94.373mb -0.00%  | 1.754ms -1.86%   | ±2.02% +45.70%  |
| RowsBench         | bench_drop_right_1k_on_10k | 2    | 3   | 94.373mb -0.00%  | 1.838ms +1.55%   | ±2.10% -19.34%  |
| RowsBench         | bench_entries_on_10k       | 2    | 3   | 92.534mb -0.00%  | 3.554ms -1.00%   | ±2.54% +127.52% |
| RowsBench         | bench_filter_on_10k        | 2    | 3   | 93.062mb -0.00%  | 15.622ms +1.90%  | ±1.76% -37.22%  |
| RowsBench         | bench_find_on_10k          | 2    | 3   | 93.062mb -0.00%  | 15.392ms -4.70%  | ±0.71% -76.42%  |
| RowsBench         | bench_find_one_on_10k      | 10   | 3   | 91.751mb -0.00%  | 1.794μs -10.30%  | ±2.67% +0.00%   |
| RowsBench         | bench_first_on_10k         | 10   | 3   | 91.751mb -0.00%  | 0.400μs 0.00%    | ±0.00% 0.00%    |
| RowsBench         | bench_flat_map_on_1k       | 2    | 3   | 100.812mb -0.00% | 14.365ms +0.64%  | ±0.79% -4.29%   |
| RowsBench         | bench_map_on_10k           | 2    | 3   | 130.239mb -0.00% | 67.822ms -6.95%  | ±1.04% -51.82%  |
| RowsBench         | bench_merge_1k_on_10k      | 2    | 3   | 93.582mb -0.00%  | 1.297ms -26.89%  | ±2.11% +15.45%  |
| RowsBench         | bench_partition_by_on_10k  | 2    | 3   | 96.970mb -0.00%  | 61.512ms -12.13% | ±0.56% -70.64%  |
| RowsBench         | bench_remove_on_10k        | 2    | 3   | 94.635mb -0.00%  | 3.465ms -18.43%  | ±3.23% -6.19%   |
| RowsBench         | bench_sort_asc_on_1k       | 2    | 3   | 92.132mb -0.00%  | 39.725ms -2.72%  | ±2.40% +14.84%  |
| RowsBench         | bench_sort_by_on_1k        | 2    | 3   | 92.132mb -0.00%  | 39.855ms -3.47%  | ±0.89% -61.28%  |
| RowsBench         | bench_sort_desc_on_1k      | 2    | 3   | 92.132mb -0.00%  | 40.713ms -3.75%  | ±1.93% +199.55% |
| RowsBench         | bench_sort_entries_on_1k   | 2    | 3   | 94.194mb -0.00%  | 7.990ms -0.70%   | ±2.62% +276.32% |
| RowsBench         | bench_sort_on_1k           | 2    | 3   | 91.944mb -0.00%  | 29.261ms -1.95%  | ±1.49% -32.58%  |
| RowsBench         | bench_take_1k_on_10k       | 10   | 3   | 91.751mb -0.00%  | 14.212μs -15.58% | ±0.66% -73.13%  |
| RowsBench         | bench_take_right_1k_on_10k | 10   | 3   | 91.751mb -0.00%  | 15.966μs -8.30%  | ±2.67% +394.09% |
| RowsBench         | bench_unique_on_1k         | 2    | 3   | 110.888mb -0.00% | 240.125ms -0.73% | ±0.36% -56.68%  |
+-------------------+----------------------------+------+-----+------------------+------------------+-----------------+
Parquet Library
+--------------------+---------------------------------+------+-----+------------------+-------------------+-----------------+
| benchmark          | subject                         | revs | its | mem_peak         | mode              | rstdev          |
+--------------------+---------------------------------+------+-----+------------------+-------------------+-----------------+
| ParquetReaderBench | bench_page_headers              | 1    | 3   | 6.685mb -0.00%   | 3.327s -1.24%     | ±0.80% +20.53%  |
| ParquetReaderBench | bench_read_metadata             | 1    | 3   | 5.370mb -0.00%   | 18.344ms -0.11%   | ±0.71% -3.79%   |
| ParquetReaderBench | bench_read_schema               | 1    | 3   | 5.370mb -0.00%   | 18.161ms -0.53%   | ±0.60% +66.00%  |
| ParquetReaderBench | bench_read_values_all_columns   | 1    | 3   | 9.120mb -0.21%   | 5.668s -28.39%    | ±1.48% +267.83% |
| ParquetReaderBench | bench_read_values_single_column | 1    | 3   | 6.417mb -0.29%   | 234.442ms -48.99% | ±0.61% +5.06%   |
| ParquetReaderBench | bench_read_values_with_limit    | 1    | 3   | 6.948mb -0.45%   | 28.955ms -14.78%  | ±0.52% +38.89%  |
| ParquetWriterBench | bench_write_batch               | 1    | 3   | 11.737mb -14.43% | 193.787ms -13.58% | ±0.47% +182.98% |
| ParquetWriterBench | bench_write_gzip                | 1    | 3   | 10.363mb +0.02%  | 217.483ms -2.40%  | ±0.23% +154.81% |
| ParquetWriterBench | bench_write_row_by_row          | 1    | 3   | 11.737mb -14.43% | 192.367ms -14.44% | ±0.62% +150.98% |
| ParquetWriterBench | bench_write_snappy              | 1    | 3   | 11.737mb -14.43% | 191.155ms -14.69% | ±0.85% +141.46% |
| ParquetWriterBench | bench_write_uncompressed        | 1    | 3   | 10.038mb +0.02%  | 190.794ms -0.05%  | ±0.56% -52.76%  |
+--------------------+---------------------------------+------+-----+------------------+-------------------+-----------------+

@norberttech norberttech merged commit af99327 into 1.x Jul 28, 2025
21 checks passed
@norberttech norberttech deleted the 1789-proposal-add-offset-method-to-dataframe branch July 28, 2025 12:15
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.

[Proposal]: Add offset method to DataFrame

2 participants