enable multithreading on PutSplunkHTTP

apache · Jan 5, 2022 · 3283a3a · 3283a3a
1 parent e130d7d
commit 3283a3a
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 4 deletions.
diff --git a/extensions/splunk/PutSplunkHTTP.h b/extensions/splunk/PutSplunkHTTP.h
@@ -48,6 +48,10 @@ class PutSplunkHTTP final : public SplunkHECProcessor {
   void onTrigger(const std::shared_ptr<core::ProcessContext> &context, const std::shared_ptr<core::ProcessSession> &session) override;
   void initialize() override;
   void onSchedule(const std::shared_ptr<core::ProcessContext> &context, const std::shared_ptr<core::ProcessSessionFactory> &sessionFactory) override;
+
+  bool isSingleThreaded() const override {
+    return false;
+  }
 };
 
 }  // namespace org::apache::nifi::minifi::extensions::splunk

diff --git a/extensions/splunk/QuerySplunkIndexingStatus.h b/extensions/splunk/QuerySplunkIndexingStatus.h
@@ -49,6 +49,10 @@ class QuerySplunkIndexingStatus final : public SplunkHECProcessor {
   void initialize() override;
   void onSchedule(const std::shared_ptr<core::ProcessContext> &context, const std::shared_ptr<core::ProcessSessionFactory> &sessionFactory) override;
 
+  bool isSingleThreaded() const override {
+    return true;
+  }
+
  protected:
   uint32_t batch_size_ = 1000;
   std::chrono::milliseconds max_age_ = std::chrono::hours(1);

diff --git a/extensions/splunk/SplunkHECProcessor.h b/extensions/splunk/SplunkHECProcessor.h
@@ -44,10 +44,6 @@ class SplunkHECProcessor : public core::Processor {
   void initialize() override;
   void onSchedule(const std::shared_ptr<core::ProcessContext> &context, const std::shared_ptr<core::ProcessSessionFactory> &sessionFactory) override;
 
-  bool isSingleThreaded() const override {
-    return true;
-  }
-
   core::annotation::Input getInputRequirement() const override {
     return core::annotation::Input::INPUT_REQUIRED;
   }