Apache/druid
1
0
Fork 0
mirror of https://github.com/apache/druid.git synced 2025-02-16 15:05:24 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add timestamp field to SegmentMetadataEvent

Browse Source
This commit is contained in:
Maytas Monsereenusorn 2024-06-14 21:10:18 -07:00
parent aec1d5ddd6
commit 07e23b35f1
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
processing/src/main/java/org/apache/druid/java/util/emitter/service/SegmentMetadataEvent.java
View File

@ -20,6 +20,7 @@
package org.apache.druid.java.util.emitter.service;
import com.fasterxml.jackson.annotation.JsonValue;
import org.apache.druid.java.util.common.DateTimes;
import org.apache.druid.java.util.emitter.core.Event;
import org.apache.druid.java.util.emitter.core.EventMap;
import org.apache.druid.timeline.DataSegment;
@ -85,7 +86,7 @@ public class SegmentMetadataEvent implements Event
)
{
this.dataSource = dataSource;
this.createdTime = createdTime;
this.createdTime = createdTime != null ? createdTime : DateTimes.nowUtc();
this.startTime = startTime;
this.endTime = endTime;
this.version = version;
@ -104,6 +105,7 @@ public class SegmentMetadataEvent implements Event
return EventMap.builder()
.put(FEED, getFeed())
.put("timestamp", createdTime.toString())
.put(DATASOURCE, dataSource)
.put(CREATED_TIME, createdTime)
.put(START_TIME, startTime)