Method Run

cmd/tempo-cli/cmd-convert-parquet-4to5.go:28–132

()

}

func (cmd *convertParquet4to5) Run() error {
	cmd.In = getPathToBlockDir(cmd.In)

	// open the input parquet file
	in, pf, err := openParquetFile(cmd.In)
	if err != nil {
		return err
	}
	defer in.Close()

	// open the input metadata file
	meta, err := readBlockMeta(cmd.In)
	if err != nil {
		return err
	}

	// create output block
	outR, outW, _, err := local.New(&local.Config{
		Path: cmd.Out,
	})
	if err != nil {
		return err
	}

	// calculate dedicated columns
	var dedicatedCols backend.DedicatedColumns

	if len(cmd.DedicatedColumns) > 0 {
		dedicatedCols = make(backend.DedicatedColumns, 0, len(cmd.DedicatedColumns))

		for _, col := range cmd.DedicatedColumns {

			var (
				typ     = backend.DedicatedColumnTypeString
				options = backend.DedicatedColumnOptions{}
			)

			col, blob := strings.CutPrefix(col, "blob/")
			if blob {
				options = append(options, backend.DedicatedColumnOptionBlob)
			}

			col, isInt := strings.CutPrefix(col, "int/")
			if isInt {
				typ = backend.DedicatedColumnTypeInt
			}

			att, err := traceql.ParseIdentifier(col)
			if err != nil {
				return err
			}

			var scope backend.DedicatedColumnScope
			switch att.Scope {
			case traceql.AttributeScopeSpan:
				scope = backend.DedicatedColumnScopeSpan
			case traceql.AttributeScopeResource:
				scope = backend.DedicatedColumnScopeResource