Function convertBlockToParquet

pkg/querier/parquet_queryable_test.go:561–590

convertBlockToParquet converts a TSDB block to parquet and uploads it to the bucket

(t *testing.T, ctx context.Context, userBucketClient objstore.Bucket, blockID ulid.ULID, blockDir string)

// convertBlockToParquet converts a TSDB block to parquet and uploads it to the bucket
func convertBlockToParquet(t *testing.T, ctx context.Context, userBucketClient objstore.Bucket, blockID ulid.ULID, blockDir string) error {
	tsdbBlock, err := tsdb.OpenBlock(nil, blockDir, chunkenc.NewPool(), tsdb.DefaultPostingsDecoderFactory)
	require.NoError(t, err)

	converterOpts := []convert.ConvertOption{
		convert.WithSortBy(labels.MetricName),
		convert.WithColDuration(time.Hour * 8),
		convert.WithRowGroupSize(1000),
		convert.WithName(blockID.String()),
	}

	numShards, err := convert.ConvertTSDBBlock(
		ctx,
		userBucketClient,
		tsdbBlock.MinTime(),
		tsdbBlock.MaxTime(),
		[]convert.Convertible{tsdbBlock},
		util_log.SLogger,
		converterOpts...,
	)
	require.NoError(t, err)

	_ = tsdbBlock.Close()

	// Write parquet converter marker
	err = parquet.WriteConverterMark(ctx, blockID, userBucketClient, numShards)
	require.NoError(t, err)

	return nil
}

func defaultOverrides(t *testing.T, queryVerticalShardSize int) *validation.Overrides {
	limits := validation.Limits{}