Versions in this module Expand all Collapse all v0 v0.0.2 Jun 26, 2023 Changes in this version + type ColumnBufferType struct + ChunkHeader *parquet.ColumnChunk + ChunkReadValues int64 + DataTable *layout.Table + DataTableNumRows int64 + DictPage *layout.Page + Footer *parquet.FileMetaData + PFile source.ParquetFile + PathStr string + RowGroupIndex int64 + SchemaHandler *schema.SchemaHandler + ThriftReader *thrift.TBufferedTransport + func NewColumnBuffer(pFile source.ParquetFile, footer *parquet.FileMetaData, ...) (*ColumnBufferType, error) + func (cbt *ColumnBufferType) NextRowGroup() error + func (cbt *ColumnBufferType) ReadPage() error + func (cbt *ColumnBufferType) ReadPageForSkip() (*layout.Page, error) + func (cbt *ColumnBufferType) ReadRows(num int64) (*layout.Table, int64) + func (cbt *ColumnBufferType) SkipRows(num int64) int64 + type ParquetReader struct + ColumnBuffers map[string]*ColumnBufferType + Footer *parquet.FileMetaData + NP int64 + ObjPartialType reflect.Type + ObjType reflect.Type + PFile source.ParquetFile + SchemaHandler *schema.SchemaHandler + func NewParquetColumnReader(pFile source.ParquetFile, np int64) (*ParquetReader, error) + func NewParquetReader(pFile source.ParquetFile, obj interface{}, np int64) (*ParquetReader, error) + func (pr *ParquetReader) GetFooterSize() (uint32, error) + func (pr *ParquetReader) GetNumRows() int64 + func (pr *ParquetReader) Read(dstInterface interface{}) error + func (pr *ParquetReader) ReadByNumber(maxReadNumber int) ([]interface{}, error) + func (pr *ParquetReader) ReadColumnByIndex(index int64, num int64) (values []interface{}, rls []int32, dls []int32, err error) + func (pr *ParquetReader) ReadColumnByPath(pathStr string, num int64) (values []interface{}, rls []int32, dls []int32, err error) + func (pr *ParquetReader) ReadFooter() error + func (pr *ParquetReader) ReadPartial(dstInterface interface{}, prefixPath string) error + func (pr *ParquetReader) ReadPartialByNumber(maxReadNumber int, prefixPath string) ([]interface{}, error) + func (pr *ParquetReader) ReadStop() + func (pr *ParquetReader) RenameSchema() + func (pr *ParquetReader) SetSchemaHandlerFromJSON(jsonSchema string) error + func (pr *ParquetReader) SkipRows(num int64) error + func (pr *ParquetReader) SkipRowsByIndex(index int64, num int64) + func (pr *ParquetReader) SkipRowsByPath(pathStr string, num int64) error