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, ...)
Constants ¶
This section is empty.
Variables ¶
View Source
var ( Records = make(map[string][]arrow.RecordBatch) RecordNames []string )
Functions ¶
func CheckArrowFile ¶
func CheckArrowFile(t *testing.T, f *os.File, mem memory.Allocator, schema *arrow.Schema, recs []arrow.RecordBatch)
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.RecordBatch)
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.RecordBatch)
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.RecordBatch, 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.RecordBatch)
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.RecordBatch, 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.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.