parquet part 3 : parquet for legacy solver

src/api/CMakeLists.txt

@@ -82,7 +82,7 @@ target_link_libraries(single_problem_api
 add_executable(antares-problem-generator main.cpp)
 target_link_libraries(antares-problem-generator
 	single_problem_api)
-copy_project_shared_lib(parquet_writer antares-problem-generator)
+copy_project_shared_lib(simulation-table-writers antares-problem-generator)
 
 install(DIRECTORY include/antares
         DESTINATION "include")

src/io/outputs/CMakeLists.txt

@@ -3,9 +3,12 @@
 # ===================================
 set(SRC_SIMU_TABLE
         SimulationTable.cpp
+        OptimisationsSimulationTable.cpp
+        include/antares/io/outputs/OptimisationsSimulationTable.h
         include/antares/io/outputs/SimulationTableEntry.h
         include/antares/io/outputs/SimulationTable.h
         include/antares/io/outputs/columns.h
+        include/antares/io/outputs/IColumnAdapterVisitor.h
         include/antares/io/outputs/storage.h)
 
 add_library(simulation-table STATIC ${SRC_SIMU_TABLE})

src/io/outputs/OptimisationsSimulationTable.cpp

@@ -0,0 +1,23 @@
+// Copyright 2007-2026, RTE (https://www.rte-france.com)
+// SPDX-License-Identifier: MPL-2.0
+
+#include "include/antares/io/outputs/OptimisationsSimulationTable.h"
+
+namespace Antares::IO::Outputs
+{
+SimulationTable* OptimisationsSimulationTable::firstOptimSimulationTable()
+{
+    return &firstOptimSimulationTable_;
+}
+
+SimulationTable* OptimisationsSimulationTable::secondOptimSimulationTable()
+{
+    return &secondOptimSimulationTable_;
+}
+
+void OptimisationsSimulationTable::clear()
+{
+    firstOptimSimulationTable_.clear();
+    secondOptimSimulationTable_.clear();
+}
+} // namespace Antares::IO::Outputs

src/io/outputs/SimulationTable.cpp

@@ -12,19 +12,18 @@ namespace Antares::IO::Outputs
 SimulationTable::SimulationTable()
 
 {
-    storage_.addIntegralColumn<unsigned int>("block");
+    storage_.addIntegralColumn("block");
     storage_.addOptionalColumn<std::string>("component");
     storage_.addStringColumn("output");
     storage_.addOptionalColumn<unsigned int>("absolute_time_index");
     storage_.addOptionalColumn<unsigned int>("block_time_index");
-    storage_.addIntegralColumn<unsigned int>("scenario_index");
+    storage_.addIntegralColumn("scenario_index");
     storage_.addOptionalColumn<double>("value");
     storage_.addOptionalColumn<Antares::Optimisation::LinearProblemApi::MipBasisStatus>(
       "basis_status");
 }
 
 SimulationTable::SimulationTable(SimulationTable&& other) noexcept:
-    buffer_(std::move(other.buffer_)),
     storage_(std::move(other.storage_))
 {
 }
@@ -41,51 +40,14 @@ void SimulationTable::addEntry(const SimulationTableEntry& entry)
     storage_.addValue("basis_status", entry.status);
 }
 
-std::string SimulationTable::headerCsvFormat() const
-{
-    std::ostringstream os;
-    bool first = true;
-    for (const auto& column: storage_.columns())
-    {
-        if (!first)
-        {
-            os << ',';
-        }
-        first = false;
-        os << column->name();
-    }
-    return os.str();
-}
-
-void SimulationTable::writeHeaderToBuffer()
-{
-    buffer_ << headerCsvFormat() << '\n';
-}
-
 const std::vector<std::unique_ptr<IColumn>>& SimulationTable::columns() const
 {
     return storage_.columns();
 }
 
-void SimulationTable::writeToBuffer()
+size_t SimulationTable::rowCount() const
 {
-    const size_t row_count = storage_.rowCount();
-    const auto& columns = storage_.columns();
-
-    for (size_t row = 0; row < row_count; ++row)
-    {
-        bool first = true;
-        for (const auto& col: columns)
-        {
-            if (!first)
-            {
-                buffer_ << ',';
-            }
-            first = false;
-            buffer_ << col->toString(row);
-        }
-        buffer_ << '\n';
-    }
+    return storage_.rowCount();
 }
 
 std::vector<std::vector<std::string>> SimulationTable::storageIntoRows() const
@@ -111,11 +73,5 @@ std::vector<std::vector<std::string>> SimulationTable::storageIntoRows() const
 void SimulationTable::clear()
 {
     storage_.clear();
-    buffer_.str("");
-}
-
-std::string SimulationTable::buffer() const
-{
-    return buffer_.str();
 }
 } // namespace Antares::IO::Outputs

src/io/outputs/include/antares/io/outputs/IColumnAdapterVisitor.h

@@ -0,0 +1,47 @@
+// Copyright 2007-2026, RTE (https://www.rte-france.com)
+// SPDX-License-Identifier: MPL-2.0
+
+#pragma once
+
+#include "antares/optimisation/linear-problem-api/hasStatus.h"
+
+namespace Antares::Writer
+{
+class IColumnAdapter;
+} // namespace Antares::Writer
+
+using namespace Antares::Writer;
+
+namespace Antares::IO::Outputs
+{
+
+// Forward declare template
+template<typename T>
+class TypedColumn;
+
+// Define type aliases
+using StringColumn = TypedColumn<std::string>;
+using IntegralColumn = TypedColumn<unsigned>;
+using DoubleColumn = TypedColumn<double>;
+
+template<typename T>
+using OptionalColumn = TypedColumn<std::optional<T>>;
+
+// ================================
+// Class IColumnAdapterVisitor
+// ================================
+class IColumnAdapterVisitor
+{
+public:
+    virtual ~IColumnAdapterVisitor() = default;
+    virtual std::shared_ptr<IColumnAdapter> visit(const StringColumn&) = 0;
+    virtual std::shared_ptr<IColumnAdapter> visit(const DoubleColumn&) = 0;
+    virtual std::shared_ptr<IColumnAdapter> visit(const IntegralColumn&) = 0;
+    virtual std::shared_ptr<IColumnAdapter> visit(const OptionalColumn<std::string>&) = 0;
+    virtual std::shared_ptr<IColumnAdapter> visit(const OptionalColumn<double>&) = 0;
+    virtual std::shared_ptr<IColumnAdapter> visit(const OptionalColumn<unsigned>&) = 0;
+
+    virtual std::shared_ptr<IColumnAdapter>
+    visit(const OptionalColumn<Optimisation::LinearProblemApi::MipBasisStatus>&) = 0;
+};
+} // namespace Antares::IO::Outputs

src/solver/optimisation/include/antares/solver/optimisation/OptimisationsSimulationTable.h → src/io/outputs/include/antares/io/outputs/OptimisationsSimulationTable.h

@@ -5,28 +5,17 @@
 
 #include "antares/io/outputs/SimulationTable.h"
 
-namespace Antares::Solver
+namespace Antares::IO::Outputs
 {
-class IResultWriter;
-}
-
 class OptimisationsSimulationTable
 {
 public:
-    void clear();
-
-    std::pair<std::string, std::string> moveBuffers();
-
-    void write();
-
-    void writeTo(const std::string& filePrefix, Antares::Solver::IResultWriter& writer);
     Antares::IO::Outputs::SimulationTable* firstOptimSimulationTable();
     Antares::IO::Outputs::SimulationTable* secondOptimSimulationTable();
-    [[nodiscard]] std::string headerCsvFormat() const;
+    void clear();
 
 private:
     Antares::IO::Outputs::SimulationTable firstOptimSimulationTable_;
     Antares::IO::Outputs::SimulationTable secondOptimSimulationTable_;
-    std::string firstOptimBuffer_;
-    std::string secondOptimBuffer_;
 };
+} // namespace Antares::IO::Outputs

src/io/outputs/include/antares/io/outputs/SimulationTable.h

@@ -17,22 +17,12 @@ class SimulationTable
     SimulationTable();
     SimulationTable(SimulationTable&& other) noexcept;
     void addEntry(const SimulationTableEntry& entry);
-    [[nodiscard]] std::string headerCsvFormat() const;
     const std::vector<std::unique_ptr<IColumn>>& columns() const;
-    void writeToBuffer();
+    size_t rowCount() const;
     void clear();
-
-    // const std::string& buffer() const;
-    [[nodiscard]] std::string buffer() const;
-
-    // gp : never called in production code, only from tests
-    // gp : should be moved as a free function in tests
-    void writeHeaderToBuffer();
-
     std::vector<std::vector<std::string>> storageIntoRows() const;
 
 private:
-    std::ostringstream buffer_;
     ColumnBasedStorage storage_;
 };
 } // namespace Antares::IO::Outputs