start the CArrowTableIterator work

Author: sfc-gh-aling

src/snowflake/connector/cpp/ArrowIterator/CArrowTableIterator.hpp

@@ -6,6 +6,8 @@
 #define PC_ARROWTABLEITERATOR_HPP
 
 #include "CArrowIterator.hpp"
+#include "nanoarrow.h"
+#include "nanoarrow.hpp"
 #include <string>
 #include <memory>
 #include <vector>
@@ -84,6 +86,16 @@ class CArrowTableIterator : public CArrowIterator
     bool& needsRebuild
     );
 
+  void replaceColumn_nanoarrow(
+    const unsigned int batchIdx,
+    const int colIdx,
+    ArrowSchemaView* newField,
+    ArrowArrayView* newColumn,
+    std::vector<ArrowSchemaView*>& futureFields,
+    std::vector<ArrowArrayView*>& futureColumns,
+    bool& needsRebuild
+    );
+
   /**
    * convert scaled fixed number column to Decimal, or Double column based on setting
    */
@@ -98,6 +110,17 @@ class CArrowTableIterator : public CArrowIterator
     bool& needsRebuild
   );
 
+  void convertScaledFixedNumberColumn_nanoarrow(
+    const unsigned int batchIdx,
+    const int colIdx,
+    ArrowSchemaView* field,
+    ArrowArrayView* columnArray,
+    const unsigned int scale,
+    std::vector<ArrowSchemaView*>& futureFields,
+    std::vector<ArrowArrayView*>& futureColumns,
+    bool& needsRebuild
+  );
+
   /**
    * convert scaled fixed number column to Decimal column
    */
@@ -112,6 +135,17 @@ class CArrowTableIterator : public CArrowIterator
     bool& needsRebuild
     );
 
+  void convertScaledFixedNumberColumnToDecimalColumn_nanoarrow(
+    const unsigned int batchIdx,
+    const int colIdx,
+    ArrowSchemaView* field,
+    ArrowArrayView* columnArray,
+    const unsigned int scale,
+    std::vector<ArrowSchemaView*>& futureFields,
+    std::vector<ArrowArrayView*>& futureColumns,
+    bool& needsRebuild
+    );
+
   /**
    * convert scaled fixed number column to Double column
    */
@@ -126,6 +160,17 @@ class CArrowTableIterator : public CArrowIterator
     bool& needsRebuild
     );
 
+  void convertScaledFixedNumberColumnToDoubleColumn_nanoarrow(
+    const unsigned int batchIdx,
+    const int colIdx,
+    ArrowSchemaView* field,
+    ArrowArrayView* columnArray,
+    const unsigned int scale,
+    std::vector<ArrowSchemaView*>& futureFields,
+    std::vector<ArrowArrayView*>& futureColumns,
+    bool& needsRebuild
+    );
+
   /**
    * convert Snowflake Time column (Arrow int32/int64) to Arrow Time column
    * Since Python/Pandas Time does not support nanoseconds, this function truncates values to microseconds if necessary
@@ -141,6 +186,17 @@ class CArrowTableIterator : public CArrowIterator
     bool& needsRebuild
     );
 
+  void convertTimeColumn_nanoarrow(
+    const unsigned int batchIdx,
+    const int colIdx,
+    ArrowSchemaView* field,
+    ArrowArrayView* columnArray,
+    const int scale,
+    std::vector<ArrowSchemaView*>& futureFields,
+    std::vector<ArrowArrayView*>& futureColumns,
+    bool& needsRebuild
+    );
+
   /**
    * convert Snowflake TimestampNTZ/TimestampLTZ column to Arrow Timestamp column
    */
@@ -156,6 +212,18 @@ class CArrowTableIterator : public CArrowIterator
     const std::string timezone=""
     );
 
+  void convertTimestampColumn_nanoarrow(
+    const unsigned int batchIdx,
+    const int colIdx,
+    ArrowSchemaView* field,
+    ArrowArrayView* columnArray,
+    const int scale,
+    std::vector<ArrowSchemaView*>& futureFields,
+    std::vector<ArrowArrayView*>& futureColumns,
+    bool& needsRebuild,
+    const std::string timezone=""
+    );
+
   /**
    * convert Snowflake TimestampTZ column to Arrow Timestamp column in UTC
    * Arrow Timestamp does not support time zone info in each value, so this method convert TimestampTZ to Arrow
@@ -174,6 +242,19 @@ class CArrowTableIterator : public CArrowIterator
     const std::string timezone
     );
 
+  void convertTimestampTZColumn_nanoarrow(
+    const unsigned int batchIdx,
+    const int colIdx,
+    ArrowSchemaView* field,
+    ArrowArrayView* columnArray,
+    const int scale,
+    const int byteLength,
+    std::vector<ArrowSchemaView*>& futureFields,
+    std::vector<ArrowArrayView*>& futureColumns,
+    bool& needsRebuild,
+    const std::string timezone
+    );
+
   /**
    * convert scaled fixed number to double
    * if scale is small, then just divide based on the scale; otherwise, convert the value to string first and then