From 07e23b35f1752b8c4f0d6dc56c9d37a8d397eec6 Mon Sep 17 00:00:00 2001 From: Maytas Monsereenusorn Date: Fri, 14 Jun 2024 21:10:18 -0700 Subject: [PATCH] Add timestamp field to SegmentMetadataEvent --- .../druid/java/util/emitter/service/SegmentMetadataEvent.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/processing/src/main/java/org/apache/druid/java/util/emitter/service/SegmentMetadataEvent.java b/processing/src/main/java/org/apache/druid/java/util/emitter/service/SegmentMetadataEvent.java index 7e249f72d0a6..c89ffa511619 100644 --- a/processing/src/main/java/org/apache/druid/java/util/emitter/service/SegmentMetadataEvent.java +++ b/processing/src/main/java/org/apache/druid/java/util/emitter/service/SegmentMetadataEvent.java @@ -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 SegmentMetadataEvent( ) { 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 EventMap toMap() return EventMap.builder() .put(FEED, getFeed()) + .put("timestamp", createdTime.toString()) .put(DATASOURCE, dataSource) .put(CREATED_TIME, createdTime) .put(START_TIME, startTime)