mirror of
https://github.com/featurebasedb/featurebase.git
synced 2026-08-28 02:44:59 +00:00
24372a9405
* change default backend to arrow file format instead of parquet
(cherry picked from commit 6d96a1474e)
53 lines
1.4 KiB
Go
53 lines
1.4 KiB
Go
// Copyright 2021 Molecula Corp. All rights reserved.
|
|
package pilosa
|
|
|
|
import (
|
|
"context"
|
|
"encoding/hex"
|
|
"math/rand"
|
|
"os"
|
|
"path/filepath"
|
|
"testing"
|
|
|
|
"github.com/apache/arrow/go/v10/arrow"
|
|
"github.com/apache/arrow/go/v10/arrow/array"
|
|
"github.com/apache/arrow/go/v10/arrow/memory"
|
|
)
|
|
|
|
func TempFileName(prefix string) string {
|
|
randBytes := make([]byte, 16)
|
|
rand.Read(randBytes)
|
|
return filepath.Join(os.TempDir(), prefix+hex.EncodeToString(randBytes))
|
|
}
|
|
|
|
func Test_TableParquet(t *testing.T) {
|
|
// create a arrow table
|
|
schema := arrow.NewSchema(
|
|
[]arrow.Field{
|
|
{Name: "num", Type: arrow.PrimitiveTypes.Float64},
|
|
},
|
|
nil, // no metadata
|
|
)
|
|
mem := memory.NewGoAllocator()
|
|
b := array.NewRecordBuilder(mem, schema)
|
|
defer b.Release()
|
|
b.Field(0).(*array.Float64Builder).AppendValues([]float64{1.0, 1.5, 2.0}, nil)
|
|
table := array.NewTableFromRecords(schema, []arrow.Record{b.NewRecord()})
|
|
defer table.Release()
|
|
fileName := TempFileName("pq-")
|
|
// save it as a parquet file
|
|
err := writeTableParquet(table, fileName)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
defer os.Remove(fileName)
|
|
|
|
// read it back in and compare the result
|
|
got, err := readTableParquetCtx(context.Background(), fileName, mem)
|
|
if err != nil {
|
|
t.Fatalf("readTableParquetCtx() error = %v", err)
|
|
}
|
|
if got.NumCols() != table.NumCols() {
|
|
t.Errorf("got:%v expected:%v", got.NumCols(), table.NumCols())
|
|
}
|
|
}
|