Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
Manager manages shared sessions, keyed by session ID.
func NewManager ¶
NewManager creates a new session manager.
func (*Manager) GetOrCreate ¶
GetOrCreate returns an existing session or creates a new one.
type Session ¶
type Session struct {
ID string
Engine *engine.Engine
PreviewLimit int
// contains filtered or unexported fields
}
Session represents a DuckDB execution context.
func NewSession ¶
NewSession creates a new session with the given connector.
func (*Session) Execute ¶
func (s *Session) Execute(ctx context.Context, query string, sw *spool.StreamWriter) (*engine.QueryResult, error)
Execute runs a SQL query, streaming Arrow batches through a pipeline:
DuckDB RecordReader → Flatten → GeoArrow → Preview + Spool Write
Flatten expands nested Struct/List/Map/Union to top-level columns. GeoArrow converts WKB binary geometry columns to native GeoArrow format. Records are NOT accumulated in memory.
func (*Session) ExecutionCount ¶
ExecutionCount returns the current execution counter value.
func (*Session) NextExecutionCount ¶ added in v0.1.2
NextExecutionCount atomically increments and returns the new execution counter. Must be called once per execute request, before any messages are sent.
func (*Session) SetPreviewLimit ¶
SetPreviewLimit updates the preview row limit.
Source Files