Skip to content

Commit

Permalink
Add segment size
Browse files Browse the repository at this point in the history
  • Loading branch information
yzang2019 committed Oct 4, 2023
1 parent 89d5711 commit c2b2336
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion cmd/changeset/changeset/export.go
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ type CSExporter struct {
outputDir string
}

func NewCSExporter(db *dbm.PrefixDB, start, end int64, concurrency int, segmentSize int, outputDir string) *CSExporter {
func NewCSExporter(db *dbm.PrefixDB, start int64, end int64, concurrency int, segmentSize int, outputDir string) *CSExporter {
return &CSExporter{
db: db,
start: start,
Expand Down
2 changes: 1 addition & 1 deletion cmd/changeset/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ func ExportChangeSetCmd() *cobra.Command {
}
cmd.PersistentFlags().Int64("start-version", 0, "start version number")
cmd.PersistentFlags().Int64("end-version", 0, "end version number")
cmd.PersistentFlags().Int64("concurrency", 10, "number of concurrent workers")
cmd.PersistentFlags().Int("concurrency", 10, "number of concurrent workers")
cmd.PersistentFlags().Int64("segment-size", 1000000, "number of blocks in each segment")

// we handle one stores at a time, because stores don't share much in db, handle concurrently reduces cache efficiency.
Expand Down

0 comments on commit c2b2336

Please sign in to comment.