dbscan

package
v0.18.30 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 4, 2026 License: AGPL-3.0 Imports: 6 Imported by: 0

Documentation

Overview

Package dbscan provides table-function sources for querying external SQL databases (PostgreSQL, MySQL) and producing columnar RecordBatches.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Scanner

type Scanner struct {
	// contains filtered or unexported fields
}

Scanner reads rows from a *sql.Rows result set into columnar RecordBatches.

func NewScanner

func NewScanner(rows *sql.Rows) (*Scanner, error)

NewScanner creates a Scanner from an open *sql.Rows. The caller should not close the Rows — the Scanner will close them when it returns nil from Next() or when Close() is called.

func (*Scanner) Close

func (s *Scanner) Close() error

Close releases the underlying sql.Rows.

func (*Scanner) Next

func (s *Scanner) Next() (*batch.RecordBatch, error)

Next returns the next batch of rows. Returns nil when all rows are consumed.

func (*Scanner) Schema

func (s *Scanner) Schema() []parquet.Column

Schema returns the inferred schema.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL