From 3283a3aa2a51c9c250a83f1128aa18631960f688 Mon Sep 17 00:00:00 2001 From: Martin Zink Date: Wed, 5 Jan 2022 13:58:43 +0100 Subject: [PATCH] enable multithreading on PutSplunkHTTP --- extensions/splunk/PutSplunkHTTP.h | 4 ++++ extensions/splunk/QuerySplunkIndexingStatus.h | 4 ++++ extensions/splunk/SplunkHECProcessor.h | 4 ---- 3 files changed, 8 insertions(+), 4 deletions(-) diff --git a/extensions/splunk/PutSplunkHTTP.h b/extensions/splunk/PutSplunkHTTP.h index 7e8f0af4527..9e8360cd20b 100644 --- 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 &context, const std::shared_ptr &session) override; void initialize() override; void onSchedule(const std::shared_ptr &context, const std::shared_ptr &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 index a00c4d1ee89..7c9b3af1aa1 100644 --- 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 &context, const std::shared_ptr &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 index a6694e5aa4d..89c14f5c50c 100644 --- 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 &context, const std::shared_ptr &sessionFactory) override; - bool isSingleThreaded() const override { - return true; - } - core::annotation::Input getInputRequirement() const override { return core::annotation::Input::INPUT_REQUIRED; }