arrdata

Documentation

Overview

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

Index

• Variables
• func CheckArrowConcurrentFile(t *testing.T, f *os.File, mem memory.Allocator, schema *arrow.Schema, ...)
• func CheckArrowFile(t *testing.T, f *os.File, mem memory.Allocator, schema *arrow.Schema, ...)
• func CheckArrowStream(t *testing.T, f *os.File, mem memory.Allocator, schema *arrow.Schema, ...)
• func WriteFile(t *testing.T, f *os.File, mem memory.Allocator, schema *arrow.Schema, ...)
• func WriteFileCompressed(t *testing.T, f *os.File, mem memory.Allocator, schema *arrow.Schema, ...)
• func WriteStream(t *testing.T, f *os.File, mem memory.Allocator, schema *arrow.Schema, ...)
• func WriteStreamCompressed(t *testing.T, f *os.File, mem memory.Allocator, schema *arrow.Schema, ...)

Variables

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

Functions

func CheckArrowConcurrentFile

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

func CheckArrowFile

func CheckArrowFile(t *testing.T, f *os.File, mem memory.Allocator, schema *arrow.Schema, recs []array.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 []array.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 []array.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 []array.Record, codec flatbuf.CompressionType)

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 []array.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 []array.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.