Method Run

cmd/tempo-cli/cmd-list-column.go:24–86

(ctx *globalOptions)

}

func (cmd *listColumnCmd) Run(ctx *globalOptions) error {
	r, _, _, err := loadBackend(&cmd.backendOptions, ctx)
	if err != nil {
		return err
	}

	meta, err := r.BlockMeta(context.TODO(), uuid.MustParse(cmd.BlockID), cmd.TenantID)
	if err != nil {
		return err
	}

	rr := vparquet3.NewBackendReaderAt(context.Background(), r, vparquet3.DataFileName, meta)
	pf, err := parquet.OpenFile(rr, int64(meta.Size_))
	if err != nil {
		return err
	}

	colIndex, _, _ := pq.GetColumnIndexByPath(pf, cmd.Column)

	for i, rg := range pf.RowGroups() {

		// choose the column mentioned in the cli param
		cc := rg.ColumnChunks()[colIndex]

		fmt.Printf("\n***************       rowgroup %d      ********************\n\n\n", i)

		pages := cc.Pages()
		idx, err := cc.ColumnIndex()
		if err != nil {
			return err
		}
		numPages := idx.NumPages()
		fmt.Println("Min Value of rowgroup", string(idx.MinValue(0).Bytes()))
		fmt.Println("Max Value of rowgroup", string(idx.MaxValue(numPages-1).Bytes()))

		buffer := make([]parquet.Value, 10000)
		for {
			pg, err := pages.ReadPage()
			if pg == nil || errors.Is(err, io.EOF) {
				break
			}

			vr := pg.Values()
			for {
				x, err := vr.ReadValues(buffer)
				for y := 0; y < x; y++ {
					fmt.Println(string(buffer[y].Bytes()))
				}

				// check for EOF after processing any returned data
				if errors.Is(err, io.EOF) {
					break
				}
				// todo: better error handling
				if err != nil {
					break
				}
			}