polish

Author: Takuka0311

Diff for: core/collection_pipeline/serializer/JsonSerializer.cpp

@@ -25,21 +25,20 @@ using namespace std;
 
 namespace logtail {
 
-
-    const char* JSON_KEY_TIME = "__time__";
-
-    // Helper function to serialize common fields (tags and time)
-    template <typename WriterType>
-    void SerializeCommonFields(const SizedMap& tags, uint64_t timestamp, WriterType& writer) {
-        // Serialize tags
-        for (const auto& tag : tags.mInner) {
-            writer.Key(tag.first.to_string().c_str());
-            writer.String(tag.second.to_string().c_str());
-        }
-        // Serialize time
-        writer.Key(JSON_KEY_TIME);
-        writer.Uint64(timestamp);
+const char* JSON_KEY_TIME = "__time__";
+
+// Helper function to serialize common fields (tags and time)
+template <typename WriterType>
+void SerializeCommonFields(const SizedMap& tags, uint64_t timestamp, WriterType& writer) {
+    // Serialize tags
+    for (const auto& tag : tags.mInner) {
+        writer.Key(tag.first.to_string().c_str());
+        writer.String(tag.second.to_string().c_str());
     }
+    // Serialize time
+    writer.Key(JSON_KEY_TIME);
+    writer.Uint64(timestamp);
+}
 
 bool JsonEventGroupSerializer::Serialize(BatchedEvents&& group, string& res, string& errorMsg) {
     if (group.mEvents.empty()) {

Diff for: core/plugin/flusher/file/FlusherFile.cpp

@@ -54,7 +54,6 @@ bool FlusherFile::Init(const Json::Value& config, Json::Value& optionalGoPipelin
         sName, fileSink, spdlog::thread_pool(), spdlog::async_overflow_policy::block);
     mFileWriter->set_pattern("%v");
 
-    mBatcher.Init(Json::Value(), this, DefaultFlushStrategyOptions{});
     mGroupSerializer = make_unique<JsonEventGroupSerializer>(this);
     mSendCnt = GetMetricsRecordRef().CreateCounter(METRIC_PLUGIN_FLUSHER_OUT_EVENT_GROUPS_TOTAL);
     return true;