Remove FilterRowsTransformer & related code (#524)

src/core/etl/README.md

@@ -672,9 +672,6 @@ $flow->process(new Rows(...))
     ->run();
 ```
 
-This function is internally using [filter transformer](src/Flow/ETL/Transformer/FilterRowsTransformer.php).
-
-
 ## Delayed Execution
 
 Reading from the source, transforming data, even loading to sink is executed only by one of the following

src/core/etl/docs/complex_transformers.md

@@ -6,16 +6,7 @@ Explanation of complex transformers and their arguments:
 
 ### Complex Transformers
 
-Below transformers might not be self descriptive and might require some additional options/dependencies.
-
-#### Transformer - FilterRows
-
-Available Filters
-
-- [all](../src/Flow/ETL/Transformer/Filter/Filter/All.php)
-- [any](../src/Flow/ETL/Transformer/Filter/Filter/Any.php)
-- [callback](../src/Flow/ETL/Transformer/Filter/Filter/Callback.php)
-- [opposite](../src/Flow/ETL/Transformer/Filter/Filter/Opposite.php)
+Below transformers might not be self-descriptive and might require some additional options/dependencies.
 
 #### Transformer - EntryNameStyleConverter
 

src/core/etl/src/Flow/ETL/DataFrame.php

@@ -31,8 +31,6 @@
 use Flow\ETL\Transformer\DropDuplicatesTransformer;
 use Flow\ETL\Transformer\EntryExpressionEvalTransformer;
 use Flow\ETL\Transformer\EntryExpressionFilterTransformer;
-use Flow\ETL\Transformer\Filter\Filter\Callback;
-use Flow\ETL\Transformer\FilterRowsTransformer;
 use Flow\ETL\Transformer\JoinEachRowsTransformer;
 use Flow\ETL\Transformer\JoinRowsTransformer;
 use Flow\ETL\Transformer\KeepEntriesTransformer;
@@ -197,18 +195,10 @@ public function fetch(?int $limit = null) : Rows
 
     /**
      * @lazy
-     *
-     * @param callable(Row $row) : bool|Reference\Expression $callback
      */
-    public function filter(callable|Reference\Expression $callback) : self
+    public function filter(Reference\Expression $callback) : self
     {
-        if ($callback instanceof Reference\Expression) {
-            $this->pipeline->add(new EntryExpressionFilterTransformer($callback));
-        }
-
-        if (\is_callable($callback)) {
-            $this->pipeline->add(new FilterRowsTransformer(new Callback($callback)));
-        }
+        $this->pipeline->add(new EntryExpressionFilterTransformer($callback));
 
         return $this;
     }

src/core/etl/src/Flow/ETL/Row.php

@@ -60,14 +60,6 @@ public function entries() : Entries
         return $this->entries;
     }
 
-    /**
-     * @param callable(Entry) : bool $callable
-     */
-    public function filter(callable $callable) : self
-    {
-        return new self($this->entries->filter($callable));
-    }
-
     /**
      * @throws InvalidArgumentException
      */

src/core/etl/src/Flow/ETL/Row/Entries.php

@@ -90,22 +90,6 @@ public function count() : int
         return \count($this->entries);
     }
 
-    /**
-     * @param callable(Entry) : bool $callable
-     */
-    public function filter(callable $callable) : self
-    {
-        $entries = [];
-
-        foreach ($this->entries as $entry) {
-            if ($callable($entry)) {
-                $entries[$entry->name()] = $entry;
-            }
-        }
-
-        return self::recreate($entries);
-    }
-
     /**
      * @throws InvalidArgumentException
      */

src/core/etl/tests/Flow/ETL/Tests/Unit/DataFrameTest.php

@@ -577,7 +577,7 @@ public function extract(FlowContext $context) : \Generator
                 }
             }
         )
-            ->filter(fn (Row $row) => $row->valueOf('id') % 2 === 0)
+            ->filter(ref('id')->mod(lit(2))->same(lit(0)))
             ->fetch();
 
         $this->assertCount(5, $rows);