Skip to content

Commit

Permalink
Fix rocky build
Browse files Browse the repository at this point in the history
  • Loading branch information
adamdebreceni committed Oct 8, 2024
1 parent 85b2110 commit 2b1465f
Show file tree
Hide file tree
Showing 5 changed files with 6 additions and 15 deletions.
3 changes: 0 additions & 3 deletions extension-utils/include/utils/ListingStateManager.h
Original file line number Diff line number Diff line change
Expand Up @@ -57,9 +57,6 @@ class ListingStateManager {
void storeState(const ListingState &latest_listing_state);

private:
static const std::string LATEST_LISTED_OBJECT_PREFIX;
static const std::string LATEST_LISTED_OBJECT_TIMESTAMP;

[[nodiscard]] static uint64_t getLatestListedKeyTimestampInMilliseconds(const std::unordered_map<std::string, std::string> &state);
[[nodiscard]] static std::unordered_set<std::string> getLatestListedKeys(const std::unordered_map<std::string, std::string> &state);

Expand Down
4 changes: 2 additions & 2 deletions extension-utils/src/utils/ListingStateManager.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -22,8 +22,8 @@

namespace org::apache::nifi::minifi::utils {

const std::string ListingStateManager::LATEST_LISTED_OBJECT_PREFIX = "listed_key.";
const std::string ListingStateManager::LATEST_LISTED_OBJECT_TIMESTAMP = "listed_timestamp";
static const std::string LATEST_LISTED_OBJECT_PREFIX = "listed_key.";
static const std::string LATEST_LISTED_OBJECT_TIMESTAMP = "listed_timestamp";

bool ListingState::wasObjectListedAlready(const ListedObject &object) const {
return listed_key_timestamp > object.getLastModified() ||
Expand Down
3 changes: 2 additions & 1 deletion extensions/mqtt/processors/PublishMQTT.h
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,8 @@ namespace org::apache::nifi::minifi::processors {
class PublishMQTT : public processors::AbstractMQTTProcessor {
public:
explicit PublishMQTT(std::string_view name, const utils::Identifier& uuid = {})
: processors::AbstractMQTTProcessor(name, uuid, std::make_shared<PublishMQTTMetrics>(*this, in_flight_message_counter_)) {
: processors::AbstractMQTTProcessor(name, uuid) {
metrics_ = gsl::make_not_null(std::make_shared<PublishMQTTMetrics>(*this, in_flight_message_counter_));
}

EXTENSIONAPI static constexpr const char* Description = "PublishMQTT serializes FlowFile content as an MQTT payload, sending the message to the configured topic and broker.";
Expand Down
3 changes: 2 additions & 1 deletion extensions/standard-processors/processors/GetFile.h
Original file line number Diff line number Diff line change
Expand Up @@ -84,7 +84,8 @@ class GetFileMetrics : public core::ProcessorMetricsImpl {
class GetFile : public core::ProcessorImpl {
public:
explicit GetFile(std::string_view name, const utils::Identifier& uuid = {})
: ProcessorImpl(name, uuid, std::make_shared<GetFileMetrics>(*this)) {
: ProcessorImpl(name, uuid) {
metrics_ = gsl::make_not_null(std::make_shared<GetFileMetrics>(*this));
}
~GetFile() override = default;

Expand Down
8 changes: 0 additions & 8 deletions utils/include/core/state/Value.h
Original file line number Diff line number Diff line change
Expand Up @@ -70,14 +70,6 @@ class ValueImpl : public Value {
return type_id;
}

static const std::type_index UINT64_TYPE;
static const std::type_index INT64_TYPE;
static const std::type_index UINT32_TYPE;
static const std::type_index INT_TYPE;
static const std::type_index BOOL_TYPE;
static const std::type_index DOUBLE_TYPE;
static const std::type_index STRING_TYPE;

protected:
template<typename T>
void setTypeId() {
Expand Down

0 comments on commit 2b1465f

Please sign in to comment.