etlparquet

Documentation

Index

• func WithUseTMPFile() decodeOptFunc
• type Iter
  • func Decode[T any](it Iter, opts ...decodeOptFunc) Iter
  • func DecodeFile[T any](it Iter) Iter
  • func Encode(it Iter) Iter
• type Row

Functions

func WithUseTMPFile

func WithUseTMPFile() decodeOptFunc

Types

type Iter

type Iter = etl.Iter

func Decode

func Decode[T any](it Iter, opts ...decodeOptFunc) Iter

Decode decodes and unmarshal []byte from 'iter' into T

func DecodeFile

func DecodeFile[T any](it Iter) Iter

DecodeFile receives a string path and outputs T.

func Encode

func Encode(it Iter) Iter

Encode returns a new iterator that will iterate over encoded parquet []byte data, it creates the schema based on the first received value.

type Row

type Row = drow.Row