Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CloseDuckDBConnection ¶
func CloseDuckDBConnection(conn adbc.Connection) error
CloseDuckDBConnection closes the DuckDB connection.
func OpenDuckDBConnection ¶
func OpenDuckDBConnection(ctx context.Context, dbURL string, additionalExtensions []DuckDBExtension) (adbc.Connection, error)
OpenDuckDBConnection opens a connection to a DuckDB database with the specified extensions.
Types ¶
type DuckDBExtension ¶
DuckDBExtension represents a DuckDB extension with its name and load preference.
func DefaultExtensions ¶
func DefaultExtensions() []DuckDBExtension
DefaultExtensions returns the default extensions to be loaded in DuckDB.
type DuckDBRecordReader ¶
type DuckDBRecordReader struct {
// contains filtered or unexported fields
}
DuckDBRecordReader implements arrio.Reader for reading records from DuckDB.
func NewDuckDBRecordReader ¶
func NewDuckDBRecordReader(ctx context.Context, conn adbc.Connection, query string) (*DuckDBRecordReader, error)
NewDuckDBRecordReader creates a new reader for reading records from DuckDB.
func (*DuckDBRecordReader) Close ¶
func (r *DuckDBRecordReader) Close() error
Close releases resources associated with the DuckDB reader.
func (*DuckDBRecordReader) Read ¶
func (r *DuckDBRecordReader) Read() (arrow.Record, error)
Read reads the next record from DuckDB.
func (*DuckDBRecordReader) Schema ¶
func (r *DuckDBRecordReader) Schema() *arrow.Schema
Schema returns the schema of the records being read from DuckDB.
type DuckDBRecordWriter ¶
type DuckDBRecordWriter struct {
// contains filtered or unexported fields
}
DuckDBRecordWriter implements arrio.Writer for writing records to DuckDB.
func NewDuckDBRecordWriter ¶
func NewDuckDBRecordWriter(ctx context.Context, conn adbc.Connection, tableName string) (*DuckDBRecordWriter, error)
NewDuckDBRecordWriter creates a new writer for writing records to DuckDB.
func (*DuckDBRecordWriter) Close ¶
func (w *DuckDBRecordWriter) Close() error
Close closes the DuckDB writer.
func (*DuckDBRecordWriter) Schema ¶
func (w *DuckDBRecordWriter) Schema() *arrow.Schema
Schema returns the schema of the records being written to DuckDB.
Source Files