Method Run

cmd/tempo-cli/cmd-convert-parquet-3to4.go:29–109

()

}

func (cmd *convertParquet3to4) 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 {
			att, err := traceql.ParseIdentifier(col)
			if err != nil {
				return err
			}

			scope := backend.DedicatedColumnScopeSpan
			if att.Scope == traceql.AttributeScopeResource {
				scope = backend.DedicatedColumnScopeResource
			}

			fmt.Printf("add dedicated column scope=%s name=%s\n", scope, att.Name)

			dedicatedCols = append(dedicatedCols, backend.DedicatedColumn{
				Scope: scope,
				Name:  att.Name,
				Type:  backend.DedicatedColumnTypeString,
			})
		}
	} else {
		dedicatedCols = meta.DedicatedColumns
	}

	// copy block
	blockCfg := &common.BlockConfig{
		BloomFP:             0.99,
		BloomShardSizeBytes: 1024 * 1024,
		Version:             vparquet4.VersionString,