Skip to content

Commit 30d673a

Browse files
committed
Address review comments.
1 parent c72107f commit 30d673a

File tree

5 files changed

+16
-12
lines changed

5 files changed

+16
-12
lines changed

components/core/src/clp_s/CMakeLists.txt

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -60,14 +60,14 @@ set(
6060
../clp/GrepCore.hpp
6161
../clp/hash_utils.cpp
6262
../clp/hash_utils.hpp
63-
../clp/ir/LogEvent.hpp
64-
../clp/ir/types.hpp
6563
../clp/ir/constants.hpp
6664
../clp/ir/EncodedTextAst.cpp
6765
../clp/ir/EncodedTextAst.hpp
66+
../clp/ir/LogEvent.hpp
6867
../clp/ir/parsing.cpp
6968
../clp/ir/parsing.hpp
7069
../clp/ir/parsing.inc
70+
../clp/ir/types.hpp
7171
../clp/LogSurgeonReader.cpp
7272
../clp/LogSurgeonReader.hpp
7373
../clp/NetworkReader.cpp

components/core/src/clp_s/ColumnWriter.cpp

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -85,13 +85,13 @@ void ClpStringColumnWriter::store(ZstdCompressor& compressor) {
8585
size_t VariableStringColumnWriter::add_value(ParsedMessage::variable_t& value) {
8686
clp::variable_dictionary_id_t id{};
8787
m_var_dict->add_entry(std::get<std::string>(value), id);
88-
m_variables.push_back(id);
88+
m_var_dict_ids.push_back(id);
8989
return sizeof(clp::variable_dictionary_id_t);
9090
}
9191

9292
void VariableStringColumnWriter::store(ZstdCompressor& compressor) {
93-
size_t size = m_variables.size() * sizeof(clp::variable_dictionary_id_t);
94-
compressor.write(reinterpret_cast<char const*>(m_variables.data()), size);
93+
auto size{m_var_dict_ids.size() * sizeof(clp::variable_dictionary_id_t)};
94+
compressor.write(reinterpret_cast<char const*>(m_var_dict_ids.data()), size);
9595
}
9696

9797
size_t DateStringColumnWriter::add_value(ParsedMessage::variable_t& value) {

components/core/src/clp_s/ColumnWriter.hpp

Lines changed: 9 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -117,6 +117,9 @@ class BooleanColumnWriter : public BaseColumnWriter {
117117

118118
class ClpStringColumnWriter : public BaseColumnWriter {
119119
public:
120+
// Types
121+
using encoded_log_dict_id_t = uint64_t;
122+
120123
// Constructor
121124
ClpStringColumnWriter(
122125
int32_t id,
@@ -141,7 +144,7 @@ class ClpStringColumnWriter : public BaseColumnWriter {
141144
* @param encoded_id
142145
* @return the encoded log dict id
143146
*/
144-
static clp::logtype_dictionary_id_t get_encoded_log_dict_id(uint64_t encoded_id) {
147+
static clp::logtype_dictionary_id_t get_encoded_log_dict_id(encoded_log_dict_id_t encoded_id) {
145148
return static_cast<clp::logtype_dictionary_id_t>(encoded_id & cLogDictIdMask);
146149
}
147150

@@ -160,7 +163,8 @@ class ClpStringColumnWriter : public BaseColumnWriter {
160163
* @param offset
161164
* @return The encoded log dict id
162165
*/
163-
static uint64_t encode_log_dict_id(clp::logtype_dictionary_id_t id, uint64_t offset) {
166+
static encoded_log_dict_id_t
167+
encode_log_dict_id(clp::logtype_dictionary_id_t id, uint64_t offset) {
164168
return static_cast<uint64_t>(id) | (offset << cOffsetBitPosition);
165169
}
166170

@@ -172,8 +176,8 @@ class ClpStringColumnWriter : public BaseColumnWriter {
172176
std::shared_ptr<LogTypeDictionaryWriter> m_log_dict;
173177
LogTypeDictionaryEntry m_logtype_entry;
174178

175-
std::vector<int64_t> m_logtypes;
176-
std::vector<int64_t> m_encoded_vars;
179+
std::vector<encoded_log_dict_id_t> m_logtypes;
180+
std::vector<clp::encoded_variable_t> m_encoded_vars;
177181
std::vector<clp::variable_dictionary_id_t> m_temp_var_dict_ids;
178182
};
179183

@@ -194,7 +198,7 @@ class VariableStringColumnWriter : public BaseColumnWriter {
194198

195199
private:
196200
std::shared_ptr<VariableDictionaryWriter> m_var_dict;
197-
std::vector<clp::variable_dictionary_id_t> m_variables;
201+
std::vector<clp::variable_dictionary_id_t> m_var_dict_ids;
198202
};
199203

200204
class DateStringColumnWriter : public BaseColumnWriter {

components/core/src/clp_s/search/QueryRunner.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -868,7 +868,7 @@ void QueryRunner::populate_string_queries(std::shared_ptr<Expression> const& exp
868868
dummy_timestamp,
869869
dummy_timestamp,
870870
m_ignore_case,
871-
m_dummy_lexer,
871+
m_placeholder_lexer,
872872
true
873873
)
874874
);

components/core/src/clp_s/search/QueryRunner.hpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -152,7 +152,7 @@ class QueryRunner : public FilterClass {
152152
std::vector<std::pair<ExpressionType, ast::OpList::iterator>>>
153153
m_expression_state;
154154

155-
log_surgeon::lexers::ByteLexer m_dummy_lexer;
155+
log_surgeon::lexers::ByteLexer m_placeholder_lexer;
156156

157157
simdjson::ondemand::parser m_array_parser;
158158
std::string m_array_search_string;

0 commit comments

Comments
 (0)