Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ParquetReader ¶
type ParquetReader struct {
// contains filtered or unexported fields
}
ParquetReader implements TableReader. It reads parquet files and returns rows.
func NewParquetReader ¶
func NewParquetReader(vrw types.ValueReadWriter, fr source.ParquetFile, sche schema.Schema) (*ParquetReader, error)
NewParquetReader creates a ParquetReader from a given fileReader. The ParquetFileInfo should describe the parquet file being read.
func OpenParquetReader ¶
func OpenParquetReader(vrw types.ValueReadWriter, path string, sch schema.Schema) (*ParquetReader, error)
OpenParquetReader opens a reader at a given path within local filesystem.
func (*ParquetReader) Close ¶
func (pr *ParquetReader) Close(ctx context.Context) error
Close should release resources being held
func (*ParquetReader) GetSchema ¶
func (pr *ParquetReader) GetSchema() schema.Schema
func (*ParquetReader) ReadSqlRow ¶
type ParquetWriter ¶
type ParquetWriter struct {
// contains filtered or unexported fields
}
func NewParquetWriter ¶
func NewParquetWriter(outSch schema.Schema, destName string) (*ParquetWriter, error)
func (*ParquetWriter) Close ¶
func (pwr *ParquetWriter) Close(ctx context.Context) error
Close should flush all writes, release resources being held
func (*ParquetWriter) GetSchema ¶
func (pwr *ParquetWriter) GetSchema() schema.Schema
func (*ParquetWriter) WriteSqlRow ¶
Source Files
Click to show internal directories.
Click to hide internal directories.