package arrdata

import "github.com/apache/arrow-go/v18/arrow/internal/arrdata"

Package arrdata exports arrays and records data ready to be used for tests.

Index

Variables

var (
	Records     = make(map[string][]arrow.Record)
	RecordNames []string
)

Functions

func CheckArrowConcurrentFile

func CheckArrowConcurrentFile(t *testing.T, f *os.File, mem memory.Allocator, schema *arrow.Schema, recs []arrow.Record)

func CheckArrowFile

func CheckArrowFile(t *testing.T, f *os.File, mem memory.Allocator, schema *arrow.Schema, recs []arrow.Record)

CheckArrowFile checks whether a given ARROW file contains the expected list of records.

func CheckArrowStream

func CheckArrowStream(t *testing.T, f *os.File, mem memory.Allocator, schema *arrow.Schema, recs []arrow.Record)

CheckArrowStream checks whether a given ARROW stream contains the expected list of records.

func WriteFile

func WriteFile(t *testing.T, f *os.File, mem memory.Allocator, schema *arrow.Schema, recs []arrow.Record)

WriteFile writes a list of records to the given file descriptor, as an ARROW file.

func WriteFileCompressed

func WriteFileCompressed(t *testing.T, f *os.File, mem memory.Allocator, schema *arrow.Schema, recs []arrow.Record, codec flatbuf.CompressionType, concurrency int)

WriteFile writes a list of records to the given file descriptor, as an ARROW file.

func WriteStream

func WriteStream(t *testing.T, f *os.File, mem memory.Allocator, schema *arrow.Schema, recs []arrow.Record)

WriteStream writes a list of records to the given file descriptor, as an ARROW stream.

func WriteStreamCompressed

func WriteStreamCompressed(t *testing.T, f *os.File, mem memory.Allocator, schema *arrow.Schema, recs []arrow.Record, codec flatbuf.CompressionType, np int)

WriteStreamCompressed writes a list of records to the given file descriptor as an ARROW stream using the provided compression type.

Source Files

arrdata.go ioutil.go

Version
v18.3.0 (latest)
Published
May 6, 2025
Platform
linux/amd64
Imports
15 packages
Last checked
2 months ago

Tools for package owners.