Versions in this module Expand all Collapse all v0 v0.1.1 Aug 31, 2024 v0.1.0 Aug 27, 2024 Changes in this version + type PostgresRecordReader struct + func (r *PostgresRecordReader) Close() error + func (r *PostgresRecordReader) Read() (arrow.Record, error) + func (r *PostgresRecordReader) Schema() *arrow.Schema + type PostgresSink struct + func NewPostgresSink(ctx context.Context, dbURL string) (*PostgresSink, error) + func (p *PostgresSink) Close() error + func (p *PostgresSink) IngestToPostgres(ctx context.Context, tableName string, schema *arrow.Schema, ...) error + type PostgresSource struct + func NewPostgresSource(ctx context.Context, dbURL string) (*PostgresSource, error) + func (p *PostgresSource) Close() error + func (p *PostgresSource) GetPostgresRecordReader(ctx context.Context, tableName string) (*PostgresRecordReader, error) + type SingleRecordReader struct + func NewSingleRecordReader(record arrow.Record) *SingleRecordReader + func (r *SingleRecordReader) Close() error + func (r *SingleRecordReader) Err() error + func (r *SingleRecordReader) Next() bool + func (r *SingleRecordReader) Record() arrow.Record + func (r *SingleRecordReader) Release() + func (r *SingleRecordReader) Retain() + func (r *SingleRecordReader) Schema() *arrow.Schema
Go to main page