Versions in this module Expand all Collapse all v18 v18.0.0 Oct 15, 2024 Changes in this version + const ExtensionMetadataKeyName + const ExtensionTypeKeyName + const MessageDictionaryBatch + const MessageNone + const MessageRecordBatch + const MessageSchema + const MessageSparseTensor + const MessageTensor + const MetadataV1 + const MetadataV2 + const MetadataV3 + const MetadataV4 + const MetadataV5 + var Magic = []byte("ARROW1") + type FileReader struct + func NewFileReader(r ReadAtSeeker, opts ...Option) (*FileReader, error) + func (f *FileReader) Close() error + func (f *FileReader) NumDictionaries() int + func (f *FileReader) NumRecords() int + func (f *FileReader) Read() (rec arrow.Record, err error) + func (f *FileReader) ReadAt(i int64) (arrow.Record, error) + func (f *FileReader) Record(i int) (arrow.Record, error) + func (f *FileReader) RecordAt(i int) (arrow.Record, error) + func (f *FileReader) Schema() *arrow.Schema + func (f *FileReader) Version() MetadataVersion + type FileWriter struct + func NewFileWriter(w io.Writer, opts ...Option) (*FileWriter, error) + func (f *FileWriter) Close() error + func (f *FileWriter) Write(rec arrow.Record) error + type Message struct + func NewMessage(meta, body *memory.Buffer) *Message + func (msg *Message) BodyLen() int64 + func (msg *Message) Release() + func (msg *Message) Retain() + func (msg *Message) Type() MessageType + func (msg *Message) Version() MetadataVersion + type MessageReader interface + Message func() (*Message, error) + Release func() + Retain func() + func NewMessageReader(r io.Reader, opts ...Option) MessageReader + type MessageType flatbuf.MessageHeader + func (m MessageType) String() string + type MetadataVersion flatbuf.MetadataVersion + func (m MetadataVersion) String() string + type Option func(*config) + func WithAllocator(mem memory.Allocator) Option + func WithCompressConcurrency(n int) Option + func WithDelayReadSchema(v bool) Option + func WithDictionaryDeltas(v bool) Option + func WithEnsureNativeEndian(v bool) Option + func WithFooterOffset(offset int64) Option + func WithLZ4() Option + func WithMinSpaceSavings(savings float64) Option + func WithSchema(schema *arrow.Schema) Option + func WithZstd() Option + type Payload struct + func (p *Payload) Meta() *memory.Buffer + func (p *Payload) Release() + func (p *Payload) SerializeBody(w io.Writer) error + type PayloadWriter interface + Close func() error + Start func() error + WritePayload func(Payload) error + type ReadAtSeeker interface + type Reader struct + func NewReader(r io.Reader, opts ...Option) (*Reader, error) + func NewReaderFromMessageReader(r MessageReader, opts ...Option) (reader *Reader, err error) + func (r *Reader) Err() error + func (r *Reader) Next() bool + func (r *Reader) Read() (arrow.Record, error) + func (r *Reader) Record() arrow.Record + func (r *Reader) Release() + func (r *Reader) Retain() + func (r *Reader) Schema() *arrow.Schema + type Writer struct + func NewWriter(w io.Writer, opts ...Option) *Writer + func NewWriterWithPayloadWriter(pw PayloadWriter, opts ...Option) *Writer + func (w *Writer) Close() error + func (w *Writer) Write(rec arrow.Record) (err error) v18.0.0-rc0 Oct 15, 2024
Go to main page