Versions in this module Expand all Collapse all v0 v0.2.0 Aug 25, 2026 Changes in this version + const FlushGraceCutoffDisabled + const ParquetNullChangedAtMessage + const ParquetNullRowIDMessage + var AdvancedQueryTemplateDuckDB = template.Must(...(...)) + var ErrListInOrderBy = fmt.Errorf("LIST type attributes cannot be used in ORDER BY") + func AppendDirtyExclusion(baseClause string, dirtyIDs []uuid.UUID) (string, []any) + func BuildBenchmarkOuterSelect(schemaID int16) string + func BuildBenchmarkS3Projection(schemaID int16) string + func BuildDuckClause(cond forma.Condition, cache forma.SchemaAttributeCache) (string, []any, error) + func BuildDuckDBQuery(tpl *template.Template, params any, q *model.FederatedAttributeQuery, ...) (string, []any, error) + func BuildListPredicate(column, operator, value string, elementType forma.ValueType) (string, any, error) + func BuildParquetScanSource(pathsSQL string, missing []NullScanColumn) string + func BuildPgMainClause(cond forma.Condition, cache forma.SchemaAttributeCache, paramIndex *int) (string, []any, error) + func BuildSchemaDrivenTemplateParams(sp *SchemaProjection, schemaID int16) map[string]any + func CastExpression(columnOrExpr string, v forma.ValueType) string + func ConvertPgMainValue(valStr string, attr string, meta forma.AttributeMetadata) (any, error) + func DuckDBNullScanType(vt forma.ValueType, itemsType forma.ValueType) string + func FederatedQueryHasHot(q *model.FederatedAttributeQuery) bool + func HashShapeParts(parts ...string) uint64 + func IsBenchmarkSchemaID(schemaID int16) bool + func IsListType(v forma.ValueType) bool + func MapValueTypeToDuckDBType(v forma.ValueType) string + func MapValueTypeToListDuckDBType(elementType forma.ValueType) string + func MergeTemplateParamsWithDirtyIDs(params any, dirtyIDs []uuid.UUID) any + func ParquetAttrColumn(attr string) string + func ParseDateValue(valStr string, meta forma.AttributeMetadata) (any, error) + func RenderDirtyIDsValuesCSV(dirtyIDs []uuid.UUID) string + func RenderDuckDBQuery(tpl *template.Template, params any, whereArgs []any) (string, []any, error) + func RenderS3ParquetPath(tmpl string, schemaID int16) (string, error) + func RenderSQLTemplate(tpl *template.Template, data any) (string, []any, error) + func ToDuckDBParam(value any, v forma.ValueType) (any, error) + func ValidateOrderByAttributesForListTypes(orderBy []model.AttributeOrder) error + func ValidateOrderByForListTypes(orderBy []forma.OrderBy, ...) error + func ValidateParquetAttrColumns(cache forma.SchemaAttributeCache) error + func WalkHybridCondition(cond forma.Condition, cache forma.SchemaAttributeCache, emit TypedLeafEmitter) (string, []any, error) + type DualClausePlan struct + DuckClause string + ParamSpan int + PgClause string + PgMainClause string + func PlanDualClauses(condition forma.Condition, eavTable string, schemaID int16, ...) (*DualClausePlan, error) + func (p *DualClausePlan) Bind(condition forma.Condition, cache forma.SchemaAttributeCache, paramIndex *int) (DualClauses, error) + type DualClauses struct + DuckArgs []any + DuckClause string + PgArgs []any + PgClause string + PgMainArgs []any + PgMainClause string + func ToDualClauses(condition forma.Condition, eavTable string, schemaID int16, ...) (DualClauses, error) + type DuckDBCompiledQuery struct + HasDirty bool + HasHot bool + Skeleton string + TplArgs []any + func CompileDuckDBQuery(tpl *template.Template, params map[string]any, ...) (*DuckDBCompiledQuery, error) + func (c *DuckDBCompiledQuery) Bind(q *model.FederatedAttributeQuery, dual DualClauses, dirtyIDs []uuid.UUID, ...) (string, []any) + type DuckLeafPayload struct + Column string + Err error + Param any + SQLOp string + TextLike bool + ValueType forma.ValueType + type HybridLeafPayload struct + Eav PgEavLeafPayload + Err error + IsMain bool + MainColumn string + MainSQLOp string + MainValue any + type ListOperatorMapping struct + DuckDBExpr string + Operator string + RequiresLambda bool + type NullScanColumn struct + DuckDBType string + Name string + type PatternKind int + const PatternKindContains + const PatternKindNone + const PatternKindPrefix + type PgEavLeafPayload struct + AttrID int16 + Err error + SQLOp string + Value any + ValueColumn string + type PgMainLeafPayload struct + Column string + Err error + SQLOp string + Skip bool + Value any + type PredicateGroup struct + Children []PredicateNode + FullyPushable bool + Logic forma.Logic + Source *forma.CompositeCondition + type PredicateLeaf struct + Attr string + Duck DuckLeafPayload + HasMeta bool + Hybrid HybridLeafPayload + Meta forma.AttributeMetadata + Operator PredicateOperator + Pattern PatternKind + PgEav PgEavLeafPayload + PgMain PgMainLeafPayload + Pushable bool + SQLOperator string + Source *forma.KvCondition + Storage PredicateStorage + type PredicateNode interface + type PredicateOperator string + const PredicateOpContains + const PredicateOpEquals + const PredicateOpGt + const PredicateOpGte + const PredicateOpLt + const PredicateOpLte + const PredicateOpNotEquals + const PredicateOpStartsWith + type PredicateStorage int + const PredicateStorageEAV + const PredicateStorageMain + type ProjectionCache struct + func NewProjectionCache() *ProjectionCache + func (c *ProjectionCache) GetOrBuild(schemaID int16, build func() (*SchemaProjection, error)) (*SchemaProjection, bool, error) + func (c *ProjectionCache) Reset() + func (c *ProjectionCache) Stats() (hits, misses int64) + type SQLGenerator struct + func NewSQLGenerator() *SQLGenerator + func (g *SQLGenerator) ToSQLClauses(condition forma.Condition, eavTable string, schemaID int16, ...) (string, []any, error) + func (g *SQLGenerator) ToSqlClauses(condition forma.Condition, eavTable string, schemaID int16, ...) (string, []any, error) + type SQLRenderer struct + func NewSQLRenderer() *SQLRenderer + func (r *SQLRenderer) Ident(name string) (string, error) + func (r *SQLRenderer) Param(v any) string + func (r *SQLRenderer) Render(tpl *template.Template, data any) (string, []any, error) + type SchemaProjection struct + AttrToMainColumn map[string]string + EAVAttrs []string + EAVPivotAttrs string + EAVPivotSelect string + HasEAVAttrs bool + OuterSelect string + PGGroupBy string + PGSourceSelect string + S3SourceSelect string + UnifiedColumnNames []string + UnifiedColumnTypes map[string]forma.ValueType + func BuildBenchmarkProjections(schemaID int16) *SchemaProjection + func BuildSchemaProjection(schemaID int16, cache forma.SchemaAttributeCache) (*SchemaProjection, error) + func (sp *SchemaProjection) BuildPGGroupByNoEAV() string + func (sp *SchemaProjection) BuildPGSelectNoEAV() string + type TypedLeafEmitter = typedLeafEmitter
Go to main page