Added withValue on Entry to simplify converting entry values through map

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

@@ -39,4 +39,9 @@ public function type() : Type;
      * @return TValue
      */
     public function value();
+
+    /**
+     * @param TValue $value
+     */
+    public function withValue(mixed $value) : self;
 }

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

@@ -111,4 +111,9 @@ public function value() : ?array
     {
         return $this->value;
     }
+
+    public function withValue(mixed $value) : Entry
+    {
+        return new self($this->name, $value);
+    }
 }

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

@@ -92,4 +92,9 @@ public function value() : ?bool
     {
         return $this->value;
     }
+
+    public function withValue(mixed $value) : Entry
+    {
+        return new self($this->name, $value);
+    }
 }

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

@@ -105,4 +105,9 @@ public function value() : ?\DateTimeInterface
     {
         return $this->value;
     }
+
+    public function withValue(mixed $value) : Entry
+    {
+        return new self($this->name, $value);
+    }
 }

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

@@ -90,4 +90,9 @@ public function value() : ?\UnitEnum
     {
         return $this->value;
     }
+
+    public function withValue(mixed $value) : Entry
+    {
+        return new self($this->name, $value);
+    }
 }

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

@@ -118,4 +118,9 @@ public function value() : ?float
     {
         return $this->value;
     }
+
+    public function withValue(mixed $value) : Entry
+    {
+        return new self($this->name, $value);
+    }
 }

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

@@ -92,4 +92,9 @@ public function value() : ?int
     {
         return $this->value;
     }
+
+    public function withValue(mixed $value) : Entry
+    {
+        return new self($this->name, $value);
+    }
 }

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

@@ -162,4 +162,9 @@ public function value() : ?string
 
         return \json_encode($this->value, JSON_THROW_ON_ERROR);
     }
+
+    public function withValue(mixed $value) : Entry
+    {
+        return new self($this->name, $value);
+    }
 }

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

@@ -120,4 +120,9 @@ public function value() : ?array
     {
         return $this->value;
     }
+
+    public function withValue(mixed $value) : Entry
+    {
+        return new self($this->name, $value, $this->type);
+    }
 }

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

@@ -123,4 +123,9 @@ public function value() : ?array
     {
         return $this->value;
     }
+
+    public function withValue(mixed $value) : Entry
+    {
+        return new self($this->name, $value, $this->type);
+    }
 }

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

@@ -95,4 +95,9 @@ public function value() : ?object
     {
         return $this->value;
     }
+
+    public function withValue(mixed $value) : Entry
+    {
+        return new self($this->name, $value);
+    }
 }

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

@@ -110,4 +110,9 @@ public function value() : ?string
     {
         return $this->value;
     }
+
+    public function withValue(mixed $value) : Entry
+    {
+        return new self($this->name, $value);
+    }
 }

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

@@ -117,4 +117,9 @@ public function value() : ?array
     {
         return $this->value;
     }
+
+    public function withValue(mixed $value) : Entry
+    {
+        return new self($this->name, $value, $this->type);
+    }
 }

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

@@ -117,4 +117,9 @@ public function value() : ?Uuid
     {
         return $this->value;
     }
+
+    public function withValue(mixed $value) : Entry
+    {
+        return new self($this->name, $value);
+    }
 }

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

@@ -145,4 +145,9 @@ public function value() : ?\DOMElement
     {
         return $this->value;
     }
+
+    public function withValue(mixed $value) : Entry
+    {
+        return new self($this->name, $value);
+    }
 }

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

@@ -146,4 +146,9 @@ public function value() : ?\DOMDocument
     {
         return $this->value;
     }
+
+    public function withValue(mixed $value) : Entry
+    {
+        return new self($this->name, $value);
+    }
 }

src/core/etl/tests/Flow/ETL/Tests/Integration/DataFrame/MapTest.php

@@ -0,0 +1,73 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Flow\ETL\Tests\Integration\DataFrame;
+
+use function Flow\ETL\DSL\{df,
+    from_array,
+    int_schema,
+    list_schema,
+    schema,
+    type_list,
+    type_string};
+use Flow\ETL\Row;
+use Flow\ETL\Tests\Integration\IntegrationTestCase;
+
+final class MapTest extends IntegrationTestCase
+{
+    public function test_using_map_to_replace_nullable_lists() : void
+    {
+        $rows = df()
+            ->read(
+                from_array(
+                    [
+                        ['id' => 1, 'tags' => ['A', 'B']],
+                        ['id' => 2, 'tags' => null],
+                        ['id' => 3, 'tags' => ['D']],
+                    ]
+                )->withSchema(
+                    schema(
+                        int_schema('id'),
+                        list_schema('tags', type_list(type_string(), true))
+                    )
+                )
+            )
+            ->map(
+                fn (Row $row) : Row => $row->map(fn (Row\Entry $e) => $e->value() === null && $e->is('tags') ? $e->withValue([]) : $e)
+            )
+            ->fetch();
+
+        self::assertEquals(
+            [
+                ['id' => 1, 'tags' => ['A', 'B']],
+                ['id' => 2, 'tags' => []],
+                ['id' => 3, 'tags' => ['D']],
+            ],
+            $rows->toArray()
+        );
+    }
+
+    public function test_using_map_to_replace_nulls() : void
+    {
+        $rows = df()
+            ->read(from_array([
+                ['id' => 1, 'name' => 'John'],
+                ['id' => 2, 'name' => null],
+                ['id' => 3, 'name' => 'Doe'],
+            ]))
+            ->map(
+                fn (Row $row) : Row => $row->map(fn (Row\Entry $e) => $e->value() === null && $e->is('name') ? $e->withValue('N/A') : $e)
+            )
+            ->fetch();
+
+        self::assertEquals(
+            [
+                ['id' => 1, 'name' => 'John'],
+                ['id' => 2, 'name' => 'N/A'],
+                ['id' => 3, 'name' => 'Doe'],
+            ],
+            $rows->toArray()
+        );
+    }
+}