Skip to content

Commit

Permalink
use renamed tokenizer
Browse files Browse the repository at this point in the history
  • Loading branch information
poyzannur committed Nov 1, 2023
1 parent f379d3f commit 440a1e9
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion pkg/bloomcompactor/bloomcompactor.go
Original file line number Diff line number Diff line change
Expand Up @@ -289,7 +289,7 @@ func CompactNewChunks(ctx context.Context, series Series, bloomShipperClient blo

// create a tokenizer
bt, _ := v1.NewBloomTokenizer(prometheus.DefaultRegisterer)
bt.PopulateSBF(&bloomForChks, series.chunks)
bt.PopulateSeriesWithBloom(&bloomForChks, series.chunks)

// Build and upload bloomBlock to storage
blocks, err := buildBloomBlock(bloomForChks, series)
Expand Down
4 changes: 2 additions & 2 deletions pkg/bloomcompactor/process_chunks_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -102,7 +102,7 @@ func Test_BuildAndQueryBloomsWithOneSeries(t *testing.T) {
bt, _ := v1.NewBloomTokenizer(prometheus.DefaultRegisterer)

for _, c := range chunks {
bt.PopulateSBF(&bloomsForChunks[0], []chunk.Chunk{c})
bt.PopulateSeriesWithBloom(&bloomsForChunks[0], []chunk.Chunk{c})
}

blockDir := t.TempDir()
Expand Down Expand Up @@ -165,7 +165,7 @@ func Test_BuildAndQueryBloomsWithNSeries(t *testing.T) {
bt, _ := v1.NewBloomTokenizer(prometheus.DefaultRegisterer)

for i, c := range chunks {
bt.PopulateSBF(&bloomsForChunks[i], []chunk.Chunk{c})
bt.PopulateSeriesWithBloom(&bloomsForChunks[i], []chunk.Chunk{c})
}

blockDir := t.TempDir()
Expand Down

0 comments on commit 440a1e9

Please sign in to comment.