Added streaming interface

Author: runette

source/pdal/pdalc_pipeline.cpp

@@ -36,6 +36,7 @@
 #include <pdal/util/Utils.hpp>
 #include <pdal/PipelineWriter.hpp>
 #include <pdal/Stage.hpp>
+#include <pdal/pdal_types.hpp>
 
 #undef min
 
@@ -271,6 +272,40 @@ extern "C"
         return result;
     }
 
+    bool PDALExecutePipelineAsStream(PDALPipelinePtr pipeline)
+    {
+        Pipeline *ptr = reinterpret_cast<Pipeline *>(pipeline);
+
+        if (ptr)
+        {
+            try
+            {
+                PipelineManager::ExecResult exec = ptr->manager->execute(ExecMode::Stream);
+                ptr->m_executed = true;
+                return true;
+            }
+            catch (const std::exception &e)
+            {
+                printf("Found error while executing pipeline: %s", e.what());
+                return false;
+            }
+        }
+        return false;
+    }
+
+    bool PDALPipelineIsStreamable(PDALPipelinePtr pipeline)
+    {
+        Pipeline *ptr = reinterpret_cast<Pipeline *>(pipeline);
+
+        if (ptr)
+        {
+            return ptr->manager->pipelineStreamable();
+        }
+        return false;
+    }
+
+
+
     bool PDALValidatePipeline(PDALPipelinePtr pipeline)
     {
         Pipeline *ptr = reinterpret_cast<Pipeline *>(pipeline);

source/pdal/pdalc_pipeline.h

@@ -136,6 +136,22 @@ PDALC_API int PDALGetPipelineLogLevel(PDALPipelinePtr pipeline);
  */
 PDALC_API int64_t PDALExecutePipeline(PDALPipelinePtr pipeline);
 
+/**
+ * Executes a pipeline as a streamable pipeline. Will run as non-streamed pipeline if the pipeline is not streamable.
+ *
+ * @param pipeline The pipeline
+ * @return The total number of points produced by the pipeline
+ */
+PDALC_API bool PDALExecutePipelineAsStream(PDALPipelinePtr pipeline);
+
+/**
+ * Determines if a pipeline is streamable
+ *
+ * @param pipeline The pipeline
+ * @return Whether the pipeline is streamable
+ */
+PDALC_API bool PDALPipelineIsStreamable(PDALPipelinePtr pipeline);
+
 /**
  * Validates a pipeline.
  *

tests/pdal/test_pdalc_pipeline.c.in

@@ -344,6 +344,31 @@ TEST testPDALExecutePipeline(void)
     PASS();
 }
 
+TEST testPDALExecutePipelineStream(void)
+{
+    PDALPipelinePtr pipeline = PDALCreatePipeline(gPipelineJson);
+    ASSERT(pipeline);
+
+    bool isStreamable = PDALPipelineIsStreamable(pipeline);
+
+    ASSERT_EQ(isStreamable, true);
+
+    bool result = PDALExecutePipelineAsStream(pipeline);
+
+    ASSERT_EQ(result, true);
+
+    result = PDALExecutePipelineAsStream(NULL);
+
+    ASSERT_EQ(result, false);
+
+    isStreamable = PDALPipelineIsStreamable(NULL);
+
+    ASSERT_EQ(isStreamable, false);
+
+    PDALDisposePipeline(pipeline);
+    PASS();
+}
+
 TEST testPDALValidatePipeline(void)
 {
     bool valid = PDALValidatePipeline(NULL);
@@ -369,6 +394,7 @@ GREATEST_SUITE(test_pdalc_pipeline)
 
     RUN_TEST(testPDALCreateAndDisposePipeline);
     RUN_TEST(testPDALExecutePipeline);
+    RUN_TEST(testPDALExecutePipelineStream);
     RUN_TEST(testPDALGetSetPipelineLog);
     RUN_TEST(testPDALGetPipelineAsString);
     RUN_TEST(testPDALGetPipelineMetadata);