From a7fe73c8d16bf2412a8383ae44ba97be39131acf Mon Sep 17 00:00:00 2001 From: yzang2019 Date: Sat, 7 Oct 2023 07:49:31 -0700 Subject: [PATCH] Add chunk file support --- changeset/export.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/changeset/export.go b/changeset/export.go index fb09186..75f1d89 100644 --- a/changeset/export.go +++ b/changeset/export.go @@ -90,7 +90,8 @@ func (exporter *Exporter) Start() error { if err := group.Wait(); err != nil { return err } - err := collectChunksToSegment(exporter.outputDir, chunkFiles) + segmentFile := filepath.Join(exporter.outputDir, fmt.Sprintf("changeset-%d-%d.zst", i, end)) + err := collectChunksToSegment(segmentFile, chunkFiles) if err != nil { return err }