Documentation
¶
Index ¶
- type Engine
- func (e *Engine) ClearTableCache()
- func (e *Engine) Close() error
- func (e *Engine) DescribeTable(ctx context.Context, tableName string) (*QueryResult, error)
- func (e *Engine) ExecuteQuery(ctx context.Context, query string) (*QueryResult, error)
- func (e *Engine) GetMetrics() *EngineMetrics
- func (e *Engine) ListTables(ctx context.Context) ([]string, error)
- func (e *Engine) RegisterTable(ctx context.Context, identifier table.Identifier, icebergTable *table.Table) error
- func (e *Engine) UnregisterTable(identifier table.Identifier) error
- type EngineConfig
- type EngineMetrics
- type QueryResult
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Engine ¶
type Engine struct {
// contains filtered or unexported fields
}
Engine provides SQL query capabilities using DuckDB with Arrow integration
func NewEngineWithConfig ¶
func NewEngineWithConfig(catalog *sqlite.Catalog, config *EngineConfig) (*Engine, error)
NewEngineWithConfig creates a new DuckDB engine with custom configuration
func (*Engine) ClearTableCache ¶
func (e *Engine) ClearTableCache()
ClearTableCache clears all cached table registrations
func (*Engine) DescribeTable ¶
DescribeTable returns schema information for a table
func (*Engine) ExecuteQuery ¶
ExecuteQuery executes a SQL query and returns the results with enterprise-grade features
func (*Engine) GetMetrics ¶
func (e *Engine) GetMetrics() *EngineMetrics
GetMetrics returns current engine performance metrics
func (*Engine) ListTables ¶
ListTables returns a list of all registered tables
func (*Engine) RegisterTable ¶
func (e *Engine) RegisterTable(ctx context.Context, identifier table.Identifier, icebergTable *table.Table) error
RegisterTable registers an Iceberg table as a DuckDB view for querying with caching
func (*Engine) UnregisterTable ¶
func (e *Engine) UnregisterTable(identifier table.Identifier) error
UnregisterTable removes a table from the cache and DuckDB
type EngineConfig ¶
type EngineConfig struct {
MaxMemoryMB int
QueryTimeoutSec int
EnableQueryLog bool
EnableOptimization bool
CacheSize int
}
EngineConfig holds configuration options for the engine
func DefaultEngineConfig ¶
func DefaultEngineConfig() *EngineConfig
DefaultEngineConfig returns a default configuration for the engine