sort by timestamp before writing

vinceanalytics · Feb 22, 2024 · 12ca2b9 · 12ca2b9
1 parent b15b6a1
commit 12ca2b9
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/internal/closter/events/build.go b/internal/closter/events/build.go
@@ -62,6 +62,9 @@ func (b *Builder) Release() {
 
 func (b *Builder) Write(list *v1.List) arrow.Record {
 	ls := list.GetItems()
+	sort.Slice(ls, func(i, j int) bool {
+		return ls[i].Timestamp < ls[j].Timestamp
+	})
 	b.r.Reserve(len(ls))
 	for _, e := range ls {
 		b.writeData(e)