column

Documentation

Index

• func NewCaseWhenExpression(branches []*caseWhenBranch, elseExpr expression) expression
• func NewColumnAlias(alias string, expr expression) expression
• func NewColumnAliasFromNameParts(alias []string, expr expression) expression
• func NewColumnReference(unparsedIdentifier string) expression
• func NewColumnReferenceWithPlanId(unparsedIdentifier string, planId int64) expression
• func NewLiteral(value any) expression
• func NewSQLExpression(expression string) expression
• func NewUnresolvedFunction(name string, args []expression, isDistinct bool) expression
• func NewUnresolvedFunctionWithColumns(name string, cols ...Column) expression
• type Alias
  • func WithAlias(name string, col Convertible) Alias
  • func (a Alias) ToProto(ctx context.Context) (*proto.Expression, error)
• type Column
  • func NewColumn(expr expression) Column
  • func OfDF(df SchemaDataFrame, colName string) Column
  • func OfDFWithRegex(df SchemaDataFrame, colRegex string) Column
  • func (c Column) Alias(alias string) Column
  • func (c Column) Asc() Column
  • func (c Column) Desc() Column
  • func (c Column) Div(other Column) Column
  • func (c Column) Eq(other Column) Column
  • func (c Column) Ge(other Column) Column
  • func (c Column) Gt(other Column) Column
  • func (c Column) Le(other Column) Column
  • func (c Column) Lt(other Column) Column
  • func (c Column) Mul(other Column) Column
  • func (c Column) Neq(other Column) Column
  • func (c Column) ToProto(ctx context.Context) (*proto.Expression, error)
• type Convertible
• type SchemaDataFrame

Functions

func NewCaseWhenExpression

func NewCaseWhenExpression(branches []*caseWhenBranch, elseExpr expression) expression

func NewColumnAlias

func NewColumnAlias(alias string, expr expression) expression

func NewColumnAliasFromNameParts

func NewColumnAliasFromNameParts(alias []string, expr expression) expression

func NewColumnReference

func NewColumnReference(unparsedIdentifier string) expression

func NewColumnReferenceWithPlanId

func NewColumnReferenceWithPlanId(unparsedIdentifier string, planId int64) expression

func NewLiteral

func NewLiteral(value any) expression

func NewSQLExpression

func NewSQLExpression(expression string) expression

func NewUnresolvedFunction

func NewUnresolvedFunction(name string, args []expression, isDistinct bool) expression

func NewUnresolvedFunctionWithColumns

func NewUnresolvedFunctionWithColumns(name string, cols ...Column) expression

Types

type Alias

type Alias struct {
	Name string
	Col  Convertible
}

func WithAlias

func WithAlias(name string, col Convertible) Alias

func (Alias) ToProto

func (a Alias) ToProto(ctx context.Context) (*proto.Expression, error)

type Column

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

func NewColumn

func NewColumn(expr expression) Column

func OfDF

func OfDF(df SchemaDataFrame, colName string) Column

func OfDFWithRegex

func OfDFWithRegex(df SchemaDataFrame, colRegex string) Column

func (Column) Alias

func (c Column) Alias(alias string) Column

func (Column) Asc

func (c Column) Asc() Column

func (Column) Desc

func (c Column) Desc() Column

func (Column) Div

func (c Column) Div(other Column) Column

func (Column) Eq

func (c Column) Eq(other Column) Column

func (Column) Ge

func (c Column) Ge(other Column) Column

func (Column) Gt

func (c Column) Gt(other Column) Column

func (Column) Le

func (c Column) Le(other Column) Column

func (Column) Lt

func (c Column) Lt(other Column) Column

func (Column) Mul

func (c Column) Mul(other Column) Column

func (Column) Neq

func (c Column) Neq(other Column) Column

func (Column) ToProto

func (c Column) ToProto(ctx context.Context) (*proto.Expression, error)

type Convertible

type Convertible interface {
	ToProto(ctx context.Context) (*proto.Expression, error)
}

Convertible is the interface for all things that can be converted into a protobuf expression.

type SchemaDataFrame

type SchemaDataFrame interface {
	PlanId() int64
	Schema(ctx context.Context) (*types.StructType, error)
}