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
- func CheckArrowConcurrentFile(t *testing.T, f *os.File, mem memory.Allocator, schema *arrow.Schema, recs []arrow.Record)
- func CheckArrowFile(t *testing.T, f *os.File, mem memory.Allocator, schema *arrow.Schema, recs []arrow.Record)
- func CheckArrowStream(t *testing.T, f *os.File, mem memory.Allocator, schema *arrow.Schema, recs []arrow.Record)
- func WriteFile(t *testing.T, f *os.File, mem memory.Allocator, schema *arrow.Schema, recs []arrow.Record)
- func WriteFileCompressed(t *testing.T, f *os.File, mem memory.Allocator, schema *arrow.Schema, recs []arrow.Record, codec flatbuf.CompressionType, concurrency int)
- func WriteStream(t *testing.T, f *os.File, mem memory.Allocator, schema *arrow.Schema, recs []arrow.Record)
- func WriteStreamCompressed(t *testing.T, f *os.File, mem memory.Allocator, schema *arrow.Schema, recs []arrow.Record, codec flatbuf.CompressionType, np int)
Variables ¶
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 ¶
- Version
- v18.3.0 (latest)
- Published
- May 6, 2025
- Platform
- linux/amd64
- Imports
- 15 packages
- Last checked
- 2 months ago –
Tools for package owners.