expr

package
v1.2.243 Latest Latest
Warning

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

 Go to latest Published: Apr 22, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Overview

Generated by chalk-private/engine/scripts/codegen_chalkgo_expr.py. DO NOT EDIT!

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateEmptyList added in v1.2.139 

func CreateEmptyList(dataType arrow.DataType, allocator memory.Allocator) (*arrowv1.ScalarListValue, error)

CreateEmptyList creates an empty list with the specified arrow type

func ProtoToArrowDataType added in v1.2.139 

func ProtoToArrowDataType(protoType *arrowv1.ArrowType) (arrow.DataType, error)

ProtoToArrowDataType converts a protobuf ArrowType to an Arrow DataType

func ToIdentifierLiteral added in v1.2.95 

func ToIdentifierLiteral(name string) *expressionv1.LogicalExprNode

func ToProto 

func ToProto(expr ExprI) (*expressionv1.LogicalExprNode, error)

ToProto converts an ExprI to a LogicalExprNode proto message

Types

type AggregateExprImpl added in v1.2.106 

type AggregateExprImpl struct {
	Expr
	Function   string
	Arguments  []Expr
	DataFrame  DataFrameExpr
	Conditions []Expr // Accumulated filter conditions
	Distinct   bool
	Selection  Expr
}

AggregateExprImpl represents an aggregation expression that returns a scalar

func (*AggregateExprImpl) Add added in v1.2.106 

func (e *AggregateExprImpl) Add(other Expr) Expr

Implement Expr interface for AggregateExprImpl

func (*AggregateExprImpl) And added in v1.2.106 

func (e *AggregateExprImpl) And(other Expr) Expr

func (*AggregateExprImpl) Apply added in v1.2.106 

func (e *AggregateExprImpl) Apply(args ...Expr) Expr

func (*AggregateExprImpl) As added in v1.2.106 

func (e *AggregateExprImpl) As(alias string) Expr

func (*AggregateExprImpl) Attr added in v1.2.106 

func (e *AggregateExprImpl) Attr(attribute string) Expr

func (*AggregateExprImpl) Div added in v1.2.106 

func (e *AggregateExprImpl) Div(other Expr) Expr

func (*AggregateExprImpl) Eq added in v1.2.106 

func (e *AggregateExprImpl) Eq(other Expr) Expr

func (*AggregateExprImpl) Ge added in v1.2.106 

func (e *AggregateExprImpl) Ge(other Expr) Expr

func (*AggregateExprImpl) Gt added in v1.2.106 

func (e *AggregateExprImpl) Gt(other Expr) Expr

func (*AggregateExprImpl) IsNotNull added in v1.2.106 

func (e *AggregateExprImpl) IsNotNull() Expr

func (*AggregateExprImpl) IsNull added in v1.2.106 

func (e *AggregateExprImpl) IsNull() Expr

func (*AggregateExprImpl) Le added in v1.2.106 

func (e *AggregateExprImpl) Le(other Expr) Expr

func (*AggregateExprImpl) Lt added in v1.2.106 

func (e *AggregateExprImpl) Lt(other Expr) Expr

func (*AggregateExprImpl) Mul added in v1.2.106 

func (e *AggregateExprImpl) Mul(other Expr) Expr

func (*AggregateExprImpl) Ne added in v1.2.106 

func (e *AggregateExprImpl) Ne(other Expr) Expr

func (*AggregateExprImpl) Not added in v1.2.106 

func (e *AggregateExprImpl) Not() Expr

func (*AggregateExprImpl) Or added in v1.2.106 

func (e *AggregateExprImpl) Or(other Expr) Expr

func (*AggregateExprImpl) String added in v1.2.106 

func (e *AggregateExprImpl) String() string

func (*AggregateExprImpl) Sub added in v1.2.106 

func (e *AggregateExprImpl) Sub(other Expr) Expr

func (*AggregateExprImpl) WithDistinct added in v1.2.106 

func (e *AggregateExprImpl) WithDistinct() *AggregateExprImpl

WithDistinct adds DISTINCT to the aggregation

type AliasExpr 

type AliasExpr struct {
	Expression Expr
	Alias      string
}

AliasExpr represents an aliased expression

func (*AliasExpr) Add 

func (e *AliasExpr) Add(other Expr) Expr

Implement Expr interface for AliasExpr

func (*AliasExpr) And 

func (e *AliasExpr) And(other Expr) Expr

func (*AliasExpr) Apply added in v1.2.95 

func (e *AliasExpr) Apply(args ...Expr) Expr

func (*AliasExpr) As 

func (e *AliasExpr) As(alias string) Expr

func (*AliasExpr) Attr 

func (e *AliasExpr) Attr(attribute string) Expr

func (*AliasExpr) Div 

func (e *AliasExpr) Div(other Expr) Expr

func (*AliasExpr) Eq 

func (e *AliasExpr) Eq(other Expr) Expr

func (*AliasExpr) Ge 

func (e *AliasExpr) Ge(other Expr) Expr

func (*AliasExpr) Gt 

func (e *AliasExpr) Gt(other Expr) Expr

func (*AliasExpr) IsNotNull 

func (e *AliasExpr) IsNotNull() Expr

func (*AliasExpr) IsNull 

func (e *AliasExpr) IsNull() Expr

func (*AliasExpr) Le 

func (e *AliasExpr) Le(other Expr) Expr

func (*AliasExpr) Lt 

func (e *AliasExpr) Lt(other Expr) Expr

func (*AliasExpr) Mul 

func (e *AliasExpr) Mul(other Expr) Expr

func (*AliasExpr) Ne 

func (e *AliasExpr) Ne(other Expr) Expr

func (*AliasExpr) Not 

func (e *AliasExpr) Not() Expr

func (*AliasExpr) Or 

func (e *AliasExpr) Or(other Expr) Expr

func (*AliasExpr) String 

func (e *AliasExpr) String() string

func (*AliasExpr) Sub 

func (e *AliasExpr) Sub(other Expr) Expr

type CallExpr 

type CallExpr struct {
	Expr
	Function Expr
	Args     []Expr
	Kwargs   map[string]Expr
}

CallExpr represents function calls and method calls

func (*CallExpr) Add 

func (e *CallExpr) Add(other Expr) Expr

Implement Expr interface for CallExpr

func (*CallExpr) And 

func (e *CallExpr) And(other Expr) Expr

func (*CallExpr) Apply added in v1.2.95 

func (e *CallExpr) Apply(args ...Expr) Expr

func (*CallExpr) As 

func (e *CallExpr) As(alias string) Expr

func (*CallExpr) Attr 

func (e *CallExpr) Attr(attribute string) Expr

func (*CallExpr) Div 

func (e *CallExpr) Div(other Expr) Expr

func (*CallExpr) Eq 

func (e *CallExpr) Eq(other Expr) Expr

func (*CallExpr) Ge 

func (e *CallExpr) Ge(other Expr) Expr

func (*CallExpr) Gt 

func (e *CallExpr) Gt(other Expr) Expr

func (*CallExpr) IsNotNull 

func (e *CallExpr) IsNotNull() Expr

func (*CallExpr) IsNull 

func (e *CallExpr) IsNull() Expr

func (*CallExpr) Le 

func (e *CallExpr) Le(other Expr) Expr

func (*CallExpr) Lt 

func (e *CallExpr) Lt(other Expr) Expr

func (*CallExpr) Mul 

func (e *CallExpr) Mul(other Expr) Expr

func (*CallExpr) Ne 

func (e *CallExpr) Ne(other Expr) Expr

func (*CallExpr) Not 

func (e *CallExpr) Not() Expr

func (*CallExpr) Or 

func (e *CallExpr) Or(other Expr) Expr

func (*CallExpr) String 

func (e *CallExpr) String() string

func (*CallExpr) Sub 

func (e *CallExpr) Sub(other Expr) Expr

type ColumnExpr 

type ColumnExpr struct {
	Expr
	Name     string
	Relation string
}

ColumnExpr represents a column reference

func (*ColumnExpr) Add 

func (e *ColumnExpr) Add(other Expr) Expr

Implement Expr interface for ColumnExpr

func (*ColumnExpr) And 

func (e *ColumnExpr) And(other Expr) Expr

func (*ColumnExpr) Apply added in v1.2.95 

func (e *ColumnExpr) Apply(args ...Expr) Expr

func (*ColumnExpr) As 

func (e *ColumnExpr) As(alias string) Expr

func (*ColumnExpr) Attr 

func (e *ColumnExpr) Attr(attribute string) Expr

func (*ColumnExpr) Div 

func (e *ColumnExpr) Div(other Expr) Expr

func (*ColumnExpr) Eq 

func (e *ColumnExpr) Eq(other Expr) Expr

func (*ColumnExpr) Ge 

func (e *ColumnExpr) Ge(other Expr) Expr

func (*ColumnExpr) Gt 

func (e *ColumnExpr) Gt(other Expr) Expr

func (*ColumnExpr) IsNotNull 

func (e *ColumnExpr) IsNotNull() Expr

func (*ColumnExpr) IsNull 

func (e *ColumnExpr) IsNull() Expr

func (*ColumnExpr) Le 

func (e *ColumnExpr) Le(other Expr) Expr

func (*ColumnExpr) Lt 

func (e *ColumnExpr) Lt(other Expr) Expr

func (*ColumnExpr) Mul 

func (e *ColumnExpr) Mul(other Expr) Expr

func (*ColumnExpr) Ne 

func (e *ColumnExpr) Ne(other Expr) Expr

func (*ColumnExpr) Not 

func (e *ColumnExpr) Not() Expr

func (*ColumnExpr) Or 

func (e *ColumnExpr) Or(other Expr) Expr

func (*ColumnExpr) String 

func (e *ColumnExpr) String() string

func (*ColumnExpr) Sub 

func (e *ColumnExpr) Sub(other Expr) Expr

func (*ColumnExpr) WithRelation 

func (e *ColumnExpr) WithRelation(relation string) *ColumnExpr

WithRelation adds a relation qualifier to the column

type DataFrameExpr 

type DataFrameExpr interface {
	ExprI

	Filter(condition ExprI) DataFrameExpr
	Select(selection Expr) DataFrameExpr
	Agg(aggFunc string, args ...Expr) Expr
}

DataFrameExpr represents expressions that operate on DataFrames

func DataFrame 

func DataFrame(name string) DataFrameExpr

DataFrame creates a dataframe reference for aggregations

type DataFrameExprImpl added in v1.2.106 

type DataFrameExprImpl struct {
	Expr
	Name       string
	Conditions []Expr // Store accumulated filter conditions
	Selection  Expr   // Store expression to be aggregated
}

DataFrameExprImpl represents a dataframe for aggregation operations

func (*DataFrameExprImpl) Add added in v1.2.106 

func (e *DataFrameExprImpl) Add(other Expr) Expr

Implement Expr interface for DataFrameExprImpl

func (*DataFrameExprImpl) Agg added in v1.2.106 

func (e *DataFrameExprImpl) Agg(aggFunc string, args ...Expr) Expr

func (*DataFrameExprImpl) And added in v1.2.106 

func (e *DataFrameExprImpl) And(other Expr) Expr

func (*DataFrameExprImpl) Apply added in v1.2.106 

func (e *DataFrameExprImpl) Apply(args ...Expr) Expr

func (*DataFrameExprImpl) As added in v1.2.106 

func (e *DataFrameExprImpl) As(alias string) Expr

func (*DataFrameExprImpl) Attr added in v1.2.106 

func (e *DataFrameExprImpl) Attr(attribute string) Expr

func (*DataFrameExprImpl) Div added in v1.2.106 

func (e *DataFrameExprImpl) Div(other Expr) Expr

func (*DataFrameExprImpl) Eq added in v1.2.106 

func (e *DataFrameExprImpl) Eq(other Expr) Expr

func (*DataFrameExprImpl) Filter added in v1.2.106 

func (e *DataFrameExprImpl) Filter(condition ExprI) DataFrameExpr

Implement DataFrameExpr interface

func (*DataFrameExprImpl) Ge added in v1.2.106 

func (e *DataFrameExprImpl) Ge(other Expr) Expr

func (*DataFrameExprImpl) Gt added in v1.2.106 

func (e *DataFrameExprImpl) Gt(other Expr) Expr

func (*DataFrameExprImpl) IsNotNull added in v1.2.106 

func (e *DataFrameExprImpl) IsNotNull() Expr

func (*DataFrameExprImpl) IsNull added in v1.2.106 

func (e *DataFrameExprImpl) IsNull() Expr

func (*DataFrameExprImpl) Le added in v1.2.106 

func (e *DataFrameExprImpl) Le(other Expr) Expr

func (*DataFrameExprImpl) Lt added in v1.2.106 

func (e *DataFrameExprImpl) Lt(other Expr) Expr

func (*DataFrameExprImpl) Mul added in v1.2.106 

func (e *DataFrameExprImpl) Mul(other Expr) Expr

func (*DataFrameExprImpl) Ne added in v1.2.106 

func (e *DataFrameExprImpl) Ne(other Expr) Expr

func (*DataFrameExprImpl) Not added in v1.2.106 

func (e *DataFrameExprImpl) Not() Expr

func (*DataFrameExprImpl) Or added in v1.2.106 

func (e *DataFrameExprImpl) Or(other Expr) Expr

func (*DataFrameExprImpl) Select added in v1.2.106 

func (e *DataFrameExprImpl) Select(selection Expr) DataFrameExpr

func (*DataFrameExprImpl) String added in v1.2.106 

func (e *DataFrameExprImpl) String() string

func (*DataFrameExprImpl) Sub added in v1.2.106 

func (e *DataFrameExprImpl) Sub(other Expr) Expr

type Expr 

type Expr interface {
	ExprI

	// Arithmetic operations
	Add(other Expr) Expr
	Sub(other Expr) Expr
	Mul(other Expr) Expr
	Div(other Expr) Expr

	// Comparison operations
	Eq(other Expr) Expr
	Ne(other Expr) Expr
	Lt(other Expr) Expr
	Le(other Expr) Expr
	Gt(other Expr) Expr
	Ge(other Expr) Expr

	// Logical operations
	And(other Expr) Expr
	Or(other Expr) Expr
	Not() Expr

	// Null checking
	IsNull() Expr
	IsNotNull() Expr

	// Attribute access
	Attr(attribute string) Expr

	// Alias
	As(alias string) Expr

	// Function application
	Apply(args ...Expr) Expr
}

func Abs 

func Abs(expr Expr) Expr

Abs Returns the absolute value of a number.

func Acos added in v1.2.152 

func Acos(expr Expr) Expr

Acos Calculates the inverse cosine in radians.

func And 

func And(arg0, arg1 Expr) Expr

And Performs logical AND operation on two boolean values.

func ArrayAdd added in v1.2.152 

func ArrayAdd(array1, array2 Expr) Expr

ArrayAdd Returns element-wise sum of two arrays.

func ArrayAverage 

func ArrayAverage(expr Expr) Expr

ArrayAverage Calculates the average of numeric values in an array.

func ArrayConstructor 

func ArrayConstructor(arg0 Expr, optional ...Expr) Expr

ArrayConstructor Creates an array from a variable number of arguments.

func ArrayCumSum added in v1.2.152 

func ArrayCumSum(array Expr) Expr

ArrayCumSum Calculates the cumulative sum of numeric values in an array.

func ArrayDistinct 

func ArrayDistinct(arr Expr) Expr

ArrayDistinct Returns an array with duplicate elements removed, preserving order.

func ArrayDuplicates added in v1.2.152 

func ArrayDuplicates(array Expr) Expr

ArrayDuplicates Returns an array containing only the duplicate elements from the input array.

func ArrayExcept added in v1.2.152 

func ArrayExcept(left_array, right_array Expr) Expr

ArrayExcept Returns elements from the first array that are not present in the second array.

func ArrayFilter added in v1.2.152 

func ArrayFilter(arr, filter Expr) Expr

ArrayFilter Filters an array using a callback function predicate.

func ArrayFrequency 

func ArrayFrequency(arg0 Expr) Expr

ArrayFrequency Returns a map of elements to their frequency counts in an array.

func ArrayHasDuplicates added in v1.2.152 

func ArrayHasDuplicates(array Expr) Expr

ArrayHasDuplicates Checks if an array contains duplicate elements.

func ArrayIntersect added in v1.2.152 

func ArrayIntersect(left_array, right_array Expr) Expr

ArrayIntersect Returns the intersection of two arrays (elements present in both arrays).

func ArrayJoin 

func ArrayJoin(arr, delimiter Expr) Expr

ArrayJoin Joins elements of an array into a string using a separator.

func ArrayMax 

func ArrayMax(arr Expr) Expr

ArrayMax Returns the maximum element in an array.

func ArrayMedian 

func ArrayMedian(expr Expr) Expr

ArrayMedian Calculates the median value of numeric elements in an array.

func ArrayMin 

func ArrayMin(arr Expr) Expr

ArrayMin Returns the minimum element in an array.

func ArrayMode 

func ArrayMode(expr Expr, tiebreak ...Expr) Expr

ArrayMode Returns the most frequently occurring element in an array.

func ArrayMultimode added in v1.2.152 

func ArrayMultimode(arg0 Expr) Expr

ArrayMultimode Returns all most frequently occurring elements in an array.

func ArrayNormalize added in v1.2.152 

func ArrayNormalize(array, p Expr) Expr

ArrayNormalize Computes the L_p normalization of a Vector.

func ArrayPosition added in v1.2.152 

func ArrayPosition(array, element Expr) Expr

ArrayPosition Returns the 1-based position of the first occurrence of an element in an array.

func ArrayReduce added in v1.2.152 

func ArrayReduce(arr, initial_value, arr_item_type, reduce Expr) Expr

ArrayReduce Applies a reduce function to each element in an array and returns the accumulated value.

func ArrayRemove added in v1.2.152 

func ArrayRemove(array, element Expr) Expr

ArrayRemove Removes all occurrences of a specified element from an array.

func ArraySort 

func ArraySort(expr Expr) Expr

ArraySort Sorts an array in ascending order.

func ArraySortDesc 

func ArraySortDesc(arg0 Expr) Expr

ArraySortDesc Sorts an array in descending order.

func ArrayStddev 

func ArrayStddev(arg0, arg1 Expr) Expr

ArrayStddev Calculates the standard deviation of numeric values in an array.

func ArraySum 

func ArraySum(expr Expr) Expr

ArraySum Calculates the sum of numeric values in an array.

func ArrayTransform added in v1.2.152 

func ArrayTransform(arr, transform Expr) Expr

ArrayTransform Applies a transformation function to each element in an array and returns a new array.

func ArraysOverlap added in v1.2.152 

func ArraysOverlap(left_array, right_array Expr) Expr

ArraysOverlap Checks if two arrays have any elements in common.

func ArraysUnion added in v1.2.152 

func ArraysUnion(arg0, arg1 Expr) Expr

ArraysUnion Returns a list of the distinct elements of the common elements

func Asin added in v1.2.152 

func Asin(expr Expr) Expr

Asin Calculates the inverse sine in radians.

func Atan added in v1.2.152 

func Atan(expr Expr) Expr

Atan Calculates the arctangent of a number in radians.

func Atan2 added in v1.2.152 

func Atan2(y, x Expr) Expr

Atan2 Calculates the arctangent of y/x in radians, handling quadrant correctly.

func BankersRound 

func BankersRound(value Expr, digits ...Expr) Expr

BankersRound Rounds a number using banker's rounding (round half to even).

func BetaCdf added in v1.2.152 

func BetaCdf(arg0, arg1, arg2 Expr) Expr

BetaCdf Compute the Beta cdf with given a, b parameters: P(N < value; a, b). The a, b parameters must be positive real numbers and value must be a real value (all of type DOUBLE). The value must lie on the interval [0, 1].

func Between added in v1.2.152 

func Between(value, low, high Expr) Expr

Between Checks if a value is between two bounds (inclusive).

func Binary 

func Binary(value []byte) Expr

Binary creates a binary literal expression

func BinaryToVector added in v1.2.152 

func BinaryToVector(arg0, arg1 Expr) Expr

BinaryToVector Returns vector from binary.

func BinomialCdf added in v1.2.152 

func BinomialCdf(arg0, arg1, arg2 Expr) Expr

BinomialCdf Compute the Binomial cdf with given numberOfTrials and successProbability (for a single trial): P(N < value). The successProbability must be real value in [0, 1], numberOfTrials and value must be positive integers with numberOfTrials greater or equal to value.

func BitwiseAnd added in v1.2.152 

func BitwiseAnd(left, right Expr) Expr

BitwiseAnd Performs bitwise AND operation on two integer values.

func BitwiseArithmeticShiftRight added in v1.2.152 

func BitwiseArithmeticShiftRight(value, shift Expr) Expr

BitwiseArithmeticShiftRight Returns the arithmetic right shift operation on x in 2’s complement representation. shift must not be negative.

func BitwiseLeftShift added in v1.2.152 

func BitwiseLeftShift(value, shift Expr) Expr

BitwiseLeftShift Returns the left shifted value of x.

func BitwiseLogicalShiftRight added in v1.2.152 

func BitwiseLogicalShiftRight(arg0, arg1, arg2 Expr) Expr

BitwiseLogicalShiftRight Returns the logical right shift operation on x (treated as bits-bit integer) shifted by shift. shift must not be negative.

func BitwiseNot added in v1.2.152 

func BitwiseNot(value Expr) Expr

BitwiseNot Performs bitwise NOT operation (complement) on an integer value.

func BitwiseOr added in v1.2.152 

func BitwiseOr(left, right Expr) Expr

BitwiseOr Performs bitwise OR operation on two integer values.

func BitwiseRightShift added in v1.2.152 

func BitwiseRightShift(value, shift Expr) Expr

BitwiseRightShift Returns the logical right shifted value of x.

func BitwiseRightShiftArithmetic added in v1.2.152 

func BitwiseRightShiftArithmetic(arg0, arg1 Expr) Expr

BitwiseRightShiftArithmetic Returns the arithmetic right shift value of x.

func BitwiseShiftLeft added in v1.2.152 

func BitwiseShiftLeft(arg0, arg1 Expr) Expr

BitwiseShiftLeft Returns the left shift operation on x (treated as bits-bit integer) shifted by shift. shift must not be negative.

func BitwiseXor added in v1.2.152 

func BitwiseXor(left, right Expr) Expr

BitwiseXor Performs bitwise XOR operation on two integer values.

func Bool 

func Bool(value bool) Expr

Bool creates a boolean literal expression

func BoostRegexpFindall 

func BoostRegexpFindall(arg0, arg1 Expr) Expr

BoostRegexpFindall Finds all matches of a regular expression pattern in a string and returns them as a list.

func BytesToStringBase64 added in v1.2.152 

func BytesToStringBase64(arg0 Expr) Expr

BytesToStringBase64 Encodes binary into a base64 string representation.

func BytesToStringHex added in v1.2.152 

func BytesToStringHex(arg0 Expr) Expr

BytesToStringHex Encodes binary into a base64 string representation.

func BytesToStringUtf8 added in v1.2.152 

func BytesToStringUtf8(arg0 Expr) Expr

BytesToStringUtf8 Encodes binary into a base64 string representation.

func Cardinality 

func Cardinality(arr Expr) Expr

Cardinality Returns the number of elements in a list.

func Cast added in v1.2.139 

func Cast(expr Expr, to *arrowv1.ArrowType) Expr

Cast converts a value to a target type

func CauchyCdf added in v1.2.152 

func CauchyCdf(arg0, arg1, arg2 Expr) Expr

CauchyCdf Compute the Cauchy cdf with given parameters median and scale (gamma): P(N; median, scale). The scale parameter must be a positive double. The value parameter must be a double on the interval [0, 1].

func Cbrt added in v1.2.152 

func Cbrt(expr Expr) Expr

Cbrt Calculates the cube root of a number.

func Ceil added in v1.2.152 

func Ceil(expr Expr) Expr

Ceil Returns the smallest integer greater than or equal to the given number.

func Ceiling 

func Ceiling(arg0 Expr) Expr

Ceiling Returns the smallest integer greater than or equal to the given number.

func ChalkNow added in v1.2.88 

func ChalkNow() Expr

func ChalkWindow added in v1.2.109 

func ChalkWindow() Expr

func ChiSquaredCdf added in v1.2.152 

func ChiSquaredCdf(arg0, arg1 Expr) Expr

ChiSquaredCdf Compute the Chi-square cdf with given df (degrees of freedom) parameter: P(N < value; df). The df parameter must be a positive real number, and value must be a non-negative real value (both of type DOUBLE).

func Chr added in v1.2.152 

func Chr(code Expr) Expr

Chr Converts an integer to its corresponding ASCII character.

func Clamp added in v1.2.152 

func Clamp(expr, min_val, max_val Expr) Expr

Clamp Constrains a value between a minimum and maximum range.

func Coalesce 

func Coalesce(vals Expr, optional ...Expr) Expr

Coalesce Returns the first non-null value from a list of arguments.

func Codepoint added in v1.2.152 

func Codepoint(arg0 Expr) Expr

Codepoint Returns the Unicode code point of the only character of the string.

func Col 

func Col(name string) Expr

Col creates a column reference expression

func ColIn added in v1.2.95 

func ColIn(relation string, name string) Expr

maybe replace with a relation.name call to Col?

func Concat 

func Concat(first, second Expr, optional ...Expr) Expr

Concat Concatenates two or more strings together.

func Contains 

func Contains(arr, value Expr) Expr

Contains Checks if a list contains a specific element.

func Cos 

func Cos(expr Expr) Expr

Cos Calculates the cosine of an angle in radians.

func Cosh added in v1.2.152 

func Cosh(expr Expr) Expr

Cosh Calculates the hyperbolic cosine of a number.

func CosineSimilarityVector added in v1.2.152 

func CosineSimilarityVector(arg0, arg1 Expr) Expr

CosineSimilarityVector Returns the cosine similarity between the vectors.

func Crc32 added in v1.2.152 

func Crc32(arg0 Expr) Expr

Crc32 Calculates the CRC32 checksum of binary data.

func CurrentDate 

func CurrentDate() Expr

CurrentDate Returns the current date.

func Date 

func Date(value time.Time) Expr

Date creates a date literal expression using Date64 (days since epoch)

func Date32 

func Date32(value int32) Expr

Date32 creates a date32 literal expression (days since epoch as int32)

func Date64 

func Date64(value int64) Expr

Date64 creates a date64 literal expression (days since epoch)

func DateAdd added in v1.2.152 

func DateAdd(arg0, arg1 Expr) Expr

DateAdd date + duration addition

func DateTrunc 

func DateTrunc(expr, unit Expr) Expr

DateTrunc Truncates a timestamp to the specified time unit (e.g., day, month, year).

func DayOfMonth 

func DayOfMonth(expr Expr) Expr

DayOfMonth Extracts the day of the month from a timestamp.

func DayOfWeek added in v1.2.152 

func DayOfWeek(expr Expr) Expr

DayOfWeek Extracts the day of the week from a timestamp.

func DayOfYear added in v1.2.152 

func DayOfYear(expr Expr) Expr

DayOfYear Extracts the day of the month from a timestamp.

func Degrees added in v1.2.152 

func Degrees(expr Expr) Expr

Degrees Converts radians to degrees.

func DistinctFrom added in v1.2.152 

func DistinctFrom(value1, value2 Expr) Expr

DistinctFrom Checks if two values are distinct, treating NULL values as different from non-NULL values.

func DotProductVector added in v1.2.152 

func DotProductVector(arg0, arg1 Expr) Expr

DotProductVector Returns the dot product between the vectors.

func DurationMicrosecond 

func DurationMicrosecond(value int64) Expr

DurationMicrosecond creates a duration in microseconds

func DurationMillisecond 

func DurationMillisecond(value int64) Expr

DurationMillisecond creates a duration in milliseconds

func DurationNanosecond 

func DurationNanosecond(value int64) Expr

DurationNanosecond creates a duration in nanoseconds

func DurationSecond 

func DurationSecond(value int64) Expr

DurationSecond creates a duration in seconds

func E added in v1.2.152 

func E() Expr

E Returns the mathematical constant e (Euler's number).

func ElementAt 

func ElementAt(arr, index Expr) Expr

ElementAt Returns the element at the specified index in a list.

func EndsWith 

func EndsWith(expr, suffix Expr) Expr

EndsWith Checks if a string ends with a specified suffix.

func Eq 

func Eq(arg0, arg1 Expr) Expr

Eq eq

func Exp added in v1.2.152 

func Exp(expr Expr) Expr

Exp Calculates e raised to the power of a number.

func FCdf added in v1.2.152 

func FCdf(arg0, arg1, arg2 Expr) Expr

FCdf Compute the F cdf with given df1 (numerator degrees of freedom) and df2 (denominator degrees of freedom) parameters: P(N < value; df1, df2). The numerator and denominator df parameters must be positive real numbers. The value must be a non-negative real number.

func Fail 

func Fail(arg0 Expr) Expr

Fail Raises an error with the specified error message.

func FindFirst added in v1.2.152 

func FindFirst(arg0, arg1 Expr) Expr

FindFirst Returns the first element in an array that matches the given predicate function.

func FindFirstIndex added in v1.2.152 

func FindFirstIndex(arg0, arg1 Expr) Expr

FindFirstIndex Returns the 1-based index of the first element in an array that matches the given predicate function.

func Flatten added in v1.2.152 

func Flatten(array Expr) Expr

Flatten Flattens a nested array by one level, combining all sub-arrays into a single array.

func Float 

func Float(value float64) Expr

Float is an alias for Float64 for convenience

func Float16 

func Float16(value float32) Expr

Float16 creates a float16 literal expression

func Float32 

func Float32(value float32) Expr

Float32 creates a float32 literal expression

func Float64 

func Float64(value float64) Expr

Float64 creates a float64 literal expression

func Floor 

func Floor(expr Expr) Expr

Floor Returns the largest integer less than or equal to the given number.

func FormatDatetime 

func FormatDatetime(input_dt, format Expr) Expr

FormatDatetime Formats a datetime using a specified format string.

func FromBase 

func FromBase(value, base Expr) Expr

FromBase Converts a string representation of a number in a given base to an integer.

func FromBase64 added in v1.2.152 

func FromBase64(arg0 Expr) Expr

FromBase64 Decodes a Base64-encoded string to binary data.

func FromBase64Url added in v1.2.152 

func FromBase64Url(arg0 Expr) Expr

FromBase64Url Decodes a Base64url-encoded string to binary data.

func FromBigEndian32 

func FromBigEndian32(expr Expr) Expr

FromBigEndian32 Convert a 32-bit big-endian bytes value to an integer.

func FromBigEndian64 

func FromBigEndian64(expr Expr) Expr

FromBigEndian64 Convert a 64-bit big-endian bytes value to an integer.

func FromHex added in v1.2.152 

func FromHex(arg0 Expr) Expr

FromHex Converts a hexadecimal string to binary data.

func FromIso8601Timestamp 

func FromIso8601Timestamp(expr Expr) Expr

FromIso8601Timestamp Parses an ISO 8601 timestamp string into a datetime object.

func FromUnixSeconds 

func FromUnixSeconds(expr Expr) Expr

FromUnixSeconds Converts Unix timestamp (seconds since epoch) to a timestamp.

func FromUnixtime added in v1.2.152 

func FromUnixtime(arg0 Expr, arg1 ...Expr) Expr

FromUnixtime Returns the UNIX timestamp unixtime as a timestamp with time zone using hours and minutes for the time zone offset.

func FromUtf8 

func FromUtf8(arg0 Expr) Expr

FromUtf8 Decodes UTF-8 encoded binary data into a string.

func FunctionCall 

func FunctionCall(name string, args ...Expr) Expr

FunctionCall creates a function call expression

func FunctionCallWithKwargs 

func FunctionCallWithKwargs(name string, args []Expr, kwargs map[string]Expr) Expr

FunctionCallWithKwargs creates a function call expression with keyword arguments

func GammaCdf added in v1.2.152 

func GammaCdf(arg0, arg1, arg2 Expr) Expr

GammaCdf Compute the Gamma cdf with given shape and scale parameters: P(N < value; shape, scale). The shape and scale parameters must be positive real numbers. The value must be a non-negative real number.

func GetJsonValue 

func GetJsonValue(json Expr, path string) Expr

GetJsonValue extracts value from JSON

func Greatest added in v1.2.152 

func Greatest(arg0 Expr, optional ...Expr) Expr

Greatest Returns the maximum value from a list of float values.

func Gt 

func Gt(arg0, arg1 Expr) Expr

Gt gt

func Gte 

func Gte(arg0, arg1 Expr) Expr

Gte gte

func Gunzip added in v1.2.152 

func Gunzip(expr Expr) Expr

Gunzip gunzip the input binary data.

func H3CellToLatLonDegrees added in v1.2.152 

func H3CellToLatLonDegrees(arg0 Expr) Expr

H3CellToLatLonDegrees Calculates the lat-lon in degrees for a given h3 cell.

func H3CellToLatLonRadians added in v1.2.152 

func H3CellToLatLonRadians(arg0 Expr) Expr

H3CellToLatLonRadians Calculates the lat-lon for a given h3 cell.

func H3LatLonToCell added in v1.2.152 

func H3LatLonToCell(lat, lon, resolution Expr) Expr

H3LatLonToCell Calculates the h3 cell for a given lat-lon.

func HammingDistance added in v1.2.152 

func HammingDistance(arg0, arg1 Expr) Expr

HammingDistance Returns the Hamming distance of string1 and string2, i.e. the number of positions at which the corresponding characters are different. Note that the two strings must have the same length.

func HmacMd5 added in v1.2.152 

func HmacMd5(arg0, arg1 Expr) Expr

HmacMd5 Computes HMAC-MD5 authentication code for data using a secret key.

func HmacSha1 added in v1.2.152 

func HmacSha1(arg0, arg1 Expr) Expr

HmacSha1 Computes HMAC-SHA1 authentication code for data using a secret key.

func HmacSha256 added in v1.2.152 

func HmacSha256(arg0, arg1 Expr) Expr

HmacSha256 Computes HMAC-SHA256 authentication code for data using a secret key.

func HmacSha512 added in v1.2.152 

func HmacSha512(arg0, arg1 Expr) Expr

HmacSha512 Computes HMAC-SHA512 authentication code for data using a secret key.

func Hour 

func Hour(arg0 Expr) Expr

Hour Extracts the hour from a timestamp.

func HttpRequest added in v1.2.152 

func HttpRequest(url, method, headers, body, allow_redirects, timeout Expr) Expr

HttpRequest Makes an HTTP request with string body and returns the response as bytes.

func Identifier 

func Identifier(name string) Expr

Identifier creates an identifier expression

func IfElse 

func IfElse(arg0, arg1, arg2 Expr) Expr

IfElse Returns the second argument if the condition is true, otherwise returns the third argument.

func Int 

func Int(value int64) Expr

Int is an alias for Int64 for convenience

func Int8 

func Int8(value int8) Expr

Int8 creates an int8 literal expression

func Int16 

func Int16(value int16) Expr

Int16 creates an int16 literal expression

func Int32 

func Int32(value int32) Expr

Int32 creates an int32 literal expression

func Int64 

func Int64(value int64) Expr

Int64 creates an int64 literal expression

func InverseBetaCdf added in v1.2.152 

func InverseBetaCdf(arg0, arg1, arg2 Expr) Expr

InverseBetaCdf Compute the inverse of the Beta cdf with given a, b parameters for the cumulative probability (p): P(N < n). The a, b parameters must be positive double values. The probability p must lie on the interval [0, 1].

func InverseBinomialCdf added in v1.2.152 

func InverseBinomialCdf(arg0, arg1, arg2 Expr) Expr

InverseBinomialCdf Compute the inverse of the Binomial cdf with given numberOfTrials and successProbability (of a single trial) the cumulative probability (p): P(N <= n). The successProbability and p must be real values in [0, 1] and the numberOfTrials must be a positive integer.

func InverseCauchyCdf added in v1.2.152 

func InverseCauchyCdf(arg0, arg1, arg2 Expr) Expr

InverseCauchyCdf Compute the inverse of the Cauchy cdf with given parameters median and scale (gamma) for the probability p. The scale parameter must be a positive double. The probability p must be a double on the interval [0, 1].

func InverseChiSquaredCdf added in v1.2.152 

func InverseChiSquaredCdf(arg0, arg1 Expr) Expr

InverseChiSquaredCdf Compute the inverse of the Chi-square cdf with given df (degrees of freedom) parameter for the cumulative probability (p): P(N < n). The df parameter must be positive real values. The probability p must lie on the interval [0, 1].

func InverseFCdf added in v1.2.152 

func InverseFCdf(arg0, arg1, arg2 Expr) Expr

InverseFCdf Compute the inverse of the Fisher F cdf with a given df1 (numerator degrees of freedom) and df2 (denominator degrees of freedom) parameters for the cumulative probability (p): P(N < n). The numerator and denominator df parameters must be positive real numbers. The probability p must lie on the interval [0, 1].

func InverseGammaCdf added in v1.2.152 

func InverseGammaCdf(arg0, arg1, arg2 Expr) Expr

InverseGammaCdf Compute the inverse of the Gamma cdf with given shape and scale parameters for the cumulative probability (p): P(N < n). The shape and scale parameters must be positive real values. The probability p must lie on the interval [0, 1].

func InverseLaplaceCdf added in v1.2.152 

func InverseLaplaceCdf(arg0, arg1, arg2 Expr) Expr

InverseLaplaceCdf Compute the inverse of the Laplace cdf with given mean and scale parameters for the cumulative probability (p): P(N < n). The mean must be a real value and the scale must be a positive real value (both of type DOUBLE). The probability p must lie on the interval [0, 1].

func InverseNormalCdf added in v1.2.152 

func InverseNormalCdf(arg0, arg1, arg2 Expr) Expr

InverseNormalCdf Compute the inverse of the Normal cdf with given mean and standard deviation (sd) for the cumulative probability (p): P(N < n). The mean must be a real value and the standard deviation must be a real and positive value (both of type DOUBLE). The probability p must lie on the interval (0, 1).

func InversePoissonCdf added in v1.2.152 

func InversePoissonCdf(arg0, arg1 Expr) Expr

InversePoissonCdf Compute the inverse of the Poisson cdf with given lambda (mean) parameter for the cumulative probability (p). It returns the value of n so that: P(N <= n; lambda) = p. The lambda parameter must be a positive real number (of type DOUBLE). The probability p must lie on the interval [0, 1).

func InverseWeibullCdf added in v1.2.152 

func InverseWeibullCdf(arg0, arg1, arg2 Expr) Expr

InverseWeibullCdf Compute the inverse of the Weibull cdf with given parameters a, b for the probability p. The a, b parameters must be positive double values. The probability p must be a double on the interval [0, 1].

func IsFederalHoliday added in v1.2.152 

func IsFederalHoliday(arg0 Expr) Expr

IsFederalHoliday Returns True if the given timestamp is a federal holiday.

func IsFinite added in v1.2.152 

func IsFinite(arg0 Expr) Expr

IsFinite Checks if a floating-point number is finite (not NaN or infinite).

func IsInfinite added in v1.2.152 

func IsInfinite(arg0 Expr) Expr

IsInfinite Checks if a floating-point number is infinite.

func IsNan 

func IsNan(arg0 Expr) Expr

IsNan Checks if a floating-point number is NaN (Not a Number).

func IsNull added in v1.2.152 

func IsNull(expr Expr) Expr

IsNull Checks if the input is null.

func JaccardSimilarity 

func JaccardSimilarity(a, b Expr) Expr

JaccardSimilarity Calculates the Jaccard similarity coefficient between two strings based on character sets.

func JaroWinklerDistance 

func JaroWinklerDistance(a, b, prefix_weight Expr) Expr

JaroWinklerDistance Calculates the Jaro-Winkler distance between two strings.

func Jinja added in v1.2.152 

func Jinja(arg0, arg1 Expr) Expr

Jinja Renders a Jinja2 template string with provided context variables.

func JsonExtractArray added in v1.2.152 

func JsonExtractArray(expr, path Expr) Expr

JsonExtractArray Extracts an array from JSON string using a path expression.

func Jsonify added in v1.2.139 

func Jsonify(expr Expr) Expr

Jsonify Converts an arbitrary value into a JSON string

func LaplaceCdf added in v1.2.152 

func LaplaceCdf(arg0, arg1, arg2 Expr) Expr

LaplaceCdf Compute the Laplace cdf with given mean and scale parameters: P(N < value; mean, scale). The mean and value must be real values and the scale parameter must be a positive value (all of type DOUBLE).

func LargeBinary 

func LargeBinary(value []byte) Expr

LargeBinary creates a large binary literal expression

func LargeUtf8 

func LargeUtf8(value string) Expr

LargeUtf8 creates a large UTF-8 string literal expression

func LastDayOfMonth 

func LastDayOfMonth(expr Expr) Expr

LastDayOfMonth Returns the last day of the month for a given date.

func Least added in v1.2.152 

func Least(arg0 Expr, optional ...Expr) Expr

Least Returns the minimum value from a list of float values.

func Length 

func Length(expr Expr) Expr

Length Returns the length of a string in characters.

func LevenshteinDistance added in v1.2.152 

func LevenshteinDistance(a, b Expr) Expr

LevenshteinDistance Calculates the Levenshtein distance between two strings.

func Like 

func Like(expr, pattern Expr) Expr

Like Checks if a string matches a pattern using SQL LIKE syntax with wildcards.

func List added in v1.2.139 

func List(items ...Expr) Expr

List creates a list literal expression Arguments must all be literals and of the same type

func Ln added in v1.2.152 

func Ln(expr Expr) Expr

Ln Calculates the natural logarithm of a number.

func Log added in v1.2.152 

func Log(arg0 Expr) Expr

Log Calculates the natural logarithm of a number.

func Log2 added in v1.2.152 

func Log2(expr Expr) Expr

Log2 Calculates the base-2 logarithm of a number.

func Log10 

func Log10(expr Expr) Expr

Log10 Calculates the base-10 logarithm of a number.

func LongestCommonSubsequence added in v1.2.152 

func LongestCommonSubsequence(a, b Expr) Expr

LongestCommonSubsequence Calculates the longest common subsequence between two strings.

func Lower 

func Lower(expr Expr) Expr

Lower Converts a string to lowercase.

func Lpad added in v1.2.152 

func Lpad(string, size, padstring Expr) Expr

Lpad Pads a string with a specified padding string on the left to reach a target length.

func Lt 

func Lt(arg0, arg1 Expr) Expr

Lt lt

func Lte 

func Lte(arg0, arg1 Expr) Expr

Lte lte

func Ltrim 

func Ltrim(expr Expr, optional ...Expr) Expr

Ltrim Removes whitespace from the left end of a string.

func MapContains 

func MapContains(arg0, arg1 Expr) Expr

MapContains Checks if a map contains any keys that match a given condition.

func MapGet 

func MapGet(mapping, key Expr) Expr

MapGet Retrieves the value associated with a key from a map.

func MapKeysByTopNValues 

func MapKeysByTopNValues(arg0, arg1 Expr) Expr

MapKeysByTopNValues Returns the keys of a map ordered by their top N highest values.

func Md5 

func Md5(expr Expr) Expr

Md5 Computes the MD5 hash of binary data.

func Millisecond added in v1.2.152 

func Millisecond(arg0 Expr) Expr

Millisecond Extracts the millisecond from a timestamp.

func Minute 

func Minute(arg0 Expr) Expr

Minute Extracts the minute from a timestamp.

func Mod 

func Mod(a, b Expr) Expr

Mod calculates modulo

func Month 

func Month(arg0 Expr) Expr

Month Extracts the month from a timestamp.

func Nan 

func Nan() Expr

Nan Returns a floating point NaN (Not a Number) value.

func Negate 

func Negate(arg0 Expr) Expr

Negate Returns the negative value of a number.

func Neq 

func Neq(arg0, arg1 Expr) Expr

Neq neq

func NormalCdf added in v1.2.152 

func NormalCdf(x, mean, std_dev Expr) Expr

NormalCdf Compute the Normal cdf with given mean and standard deviation (sd): P(N < value; mean, sd). The mean and value must be real values and the standard deviation must be a real and positive value (all of type DOUBLE).

func Null 

func Null() Expr

Null creates a null literal expression

func OpenaiComplete added in v1.2.152 

func OpenaiComplete(api_key, prompt, model, max_tokens, temperature Expr) Expr

OpenaiComplete Makes a completion request to OpenAI's chat API and returns the response.

func ParseDatetime 

func ParseDatetime(expr, format Expr) Expr

ParseDatetime Converts an ISO 8601 string into a datetime.

func PartialRatio 

func PartialRatio(a, b Expr) Expr

PartialRatio Calculates the partial ratio similarity between two strings using fuzzy matching.

func Pi added in v1.2.152 

func Pi() Expr

Pi Returns the mathematical constant π (pi).

func PoissonCdf added in v1.2.152 

func PoissonCdf(arg0, arg1 Expr) Expr

PoissonCdf Compute the Poisson cdf with given lambda (mean) parameter: P(N <= value; lambda). The lambda parameter must be a positive real number (of type DOUBLE) and value must be a non-negative integer.

func Pow added in v1.2.152 

func Pow(base, exponent Expr) Expr

Pow Raises a number to the power of another number.

func Power added in v1.2.152 

func Power(a, b Expr) Expr

Power Raises the first number to the power of the second number.

func ProtoDeserialize added in v1.2.152 

func ProtoDeserialize(arg0, arg1, arg2, arg3 Expr) Expr

ProtoDeserialize Converts protobuf binary data to a structured format.

func ProtoSerialize added in v1.2.152 

func ProtoSerialize(arg0, arg1, arg2, arg3 Expr) Expr

ProtoSerialize Converts protobuf binary data to a structured format.

func ProtoToStruct added in v1.2.152 

func ProtoToStruct(arg0, arg1, arg2, arg3 Expr) Expr

ProtoToStruct Converts protobuf binary data to a structured format.

func Quarter added in v1.2.152 

func Quarter(expr Expr) Expr

Quarter Extracts the quarter of the year from a timestamp.

func Radians added in v1.2.152 

func Radians(expr Expr) Expr

Radians Converts degrees to radians.

func Rand added in v1.2.140 

func Rand() Expr

Rand Generates a random float between 0 and 1.

func Random added in v1.2.152 

func Random(n ...Expr) Expr

Random Generates a pseudo-random float between 0 and 1.

func Recover added in v1.2.152 

func Recover(vals Expr, optional ...Expr) Expr

Recover Return the first valid entry. Functions like coalesce, but allows recovering from an upstream failure

func RegexpExtract added in v1.2.152 

func RegexpExtract(expr, pattern Expr, group ...Expr) Expr

RegexpExtract Returns the first substring matched by the regular expression pattern in string.

func RegexpExtractAll added in v1.2.152 

func RegexpExtractAll(expr, pattern Expr, group ...Expr) Expr

RegexpExtractAll Returns the substring(s) matched by the regular expression pattern in string.

func RegexpLike 

func RegexpLike(expr, pattern Expr) Expr

RegexpLike Checks if a string matches a regular expression pattern.

func RegexpReplace 

func RegexpReplace(expr, pattern Expr, replacement ...Expr) Expr

RegexpReplace Replaces all matches of a regular expression pattern with a replacement string.

func RegexpSplit added in v1.2.152 

func RegexpSplit(expr, pattern Expr) Expr

RegexpSplit Splits a string by a regex pattern into a list of strings.

func RemoveNulls added in v1.2.152 

func RemoveNulls(array Expr) Expr

RemoveNulls Removes all null values from an array.

func Replace 

func Replace(expr, old, new Expr) Expr

Replace Replaces all occurrences of a substring with another string.

func Reverse 

func Reverse(expr Expr) Expr

Reverse Reverses the characters in a string.

func Round 

func Round(value Expr, digits ...Expr) Expr

Round Rounds a floating point number to the nearest integer.

func Rpad added in v1.2.152 

func Rpad(string, size, padstring Expr) Expr

Rpad Pads a string with a specified padding string on the right to reach a target length.

func Rtrim 

func Rtrim(expr Expr, optional ...Expr) Expr

Rtrim Removes whitespace from the right end of a string.

func ScalarMax 

func ScalarMax(arg0, arg1 Expr) Expr

ScalarMax Returns the maximum of two scalar values.

func ScalarMin 

func ScalarMin(arg0, arg1 Expr) Expr

ScalarMin Returns the minimum of two scalar values.

func ScaleVector added in v1.2.152 

func ScaleVector(array, p Expr) Expr

ScaleVector Returns a scaled vector.

func Second 

func Second(arg0 Expr) Expr

Second Extracts the second from a timestamp.

func SecureRandom added in v1.2.152 

func SecureRandom(min_val ...Expr) Expr

SecureRandom Generates a cryptographically secure random float between 0 and 1.

func Sequence added in v1.2.152 

func Sequence(start, stop Expr, step ...Expr) Expr

Sequence Generates a sequence of integers from start to stop (inclusive).

func SequenceMatcherRatio 

func SequenceMatcherRatio(a, b Expr) Expr

SequenceMatcherRatio Computes the similarity ratio between two strings using sequence matching.

func Sha1 

func Sha1(expr Expr) Expr

Sha1 Computes the SHA-1 hash of binary data.

func Sha256 

func Sha256(expr Expr) Expr

Sha256 Computes the SHA-256 hash of binary data.

func Sha512 

func Sha512(expr Expr) Expr

Sha512 Computes the SHA-512 hash of binary data.

func Shuffle added in v1.2.152 

func Shuffle(array Expr) Expr

Shuffle Randomly shuffles the elements of an array.

func Sign added in v1.2.152 

func Sign(expr Expr) Expr

Sign Returns the sign of a number (-1, 0, or 1).

func Sin 

func Sin(expr Expr) Expr

Sin Calculates the sine of an angle in radians.

func Slice 

func Slice(arr, offset, length Expr) Expr

Slice Returns a slice of a list starting at the given position for the specified length.

func Split 

func Split(expr, delimiter Expr, maxsplit ...Expr) Expr

Split Splits a string by a delimiter into a list of strings.

func SplitPart added in v1.2.152 

func SplitPart(expr, delimiter, index Expr) Expr

SplitPart Splits a string by delimiter and returns the part at the specified index (1-based).

func SpookyHashV232 

func SpookyHashV232(expr Expr) Expr

SpookyHashV232 Computes a 32-bit SpookyHash V2 hash of binary data.

func SpookyHashV264 

func SpookyHashV264(expr Expr) Expr

SpookyHashV264 Computes a 64-bit SpookyHash V2 hash of binary data.

func Sqrt 

func Sqrt(expr Expr) Expr

Sqrt Calculates the square root of a number.

func StartsWith 

func StartsWith(expr, prefix Expr) Expr

StartsWith Checks if a string starts with a specified prefix.

func String 

func String(value string) Expr

String is an alias for Utf8 for convenience

func StringToBytesBase64 added in v1.2.152 

func StringToBytesBase64(arg0 Expr) Expr

StringToBytesBase64 Decodes a Base64-encoded string back into its original binary form. This function is capable of handling both fully padded and non-padded Base64 encoded strings. Partially padded Base64 strings are not supported and will result in a “UserError” status being returned.

func StringToBytesHex added in v1.2.152 

func StringToBytesHex(arg0 Expr) Expr

StringToBytesHex Decodes binary data from the hex encoded string.

func StringToBytesUtf8 added in v1.2.152 

func StringToBytesUtf8(arg0 Expr) Expr

StringToBytesUtf8 Encodes string into a UTF-8 varbinary representation.

func Strpos 

func Strpos(expr, substring Expr) Expr

Strpos Returns the position of the first occurrence of a substring within a string.

func Strrpos 

func Strrpos(expr, substring Expr) Expr

Strrpos Returns the position of the last occurrence of a substring within a string.

func StructPack added in v1.2.140 

func StructPack(fields []StructField) Expr

StructPack Create a struct value with the given columns.

func StructToProto added in v1.2.152 

func StructToProto(arg0, arg1, arg2 Expr) Expr

StructToProto Converts structured data to protobuf binary format.

func Substr 

func Substr(expr, start Expr, length ...Expr) Expr

Substr Returns a substring starting at the specified position.

func Tan 

func Tan(arg0 Expr) Expr

Tan Calculates the tangent of an angle in radians.

func Tanh added in v1.2.152 

func Tanh(expr Expr) Expr

Tanh Calculates the hyperbolic tangent of a number.

func Timestamp 

func Timestamp(value time.Time) Expr

Timestamp creates a timestamp literal expression with nanosecond precision (alias for convenience)

func TimestampMicrosecond 

func TimestampMicrosecond(value time.Time) Expr

TimestampMicrosecond creates a timestamp literal expression with microsecond precision

func TimestampMillisecond 

func TimestampMillisecond(value time.Time) Expr

TimestampMillisecond creates a timestamp literal expression with millisecond precision

func TimestampNanosecond 

func TimestampNanosecond(value time.Time) Expr

TimestampNanosecond creates a timestamp literal expression with nanosecond precision

func TimestampSecond 

func TimestampSecond(value time.Time) Expr

TimestampSecond creates a timestamp literal expression with second precision

func ToBase added in v1.2.152 

func ToBase(number, base Expr) Expr

ToBase Converts an integer to its string representation in the specified base.

func ToBase64 added in v1.2.152 

func ToBase64(arg0 Expr) Expr

ToBase64 Encodes binary data to a Base64 string.

func ToBase64Url added in v1.2.152 

func ToBase64Url(arg0 Expr) Expr

ToBase64Url Encodes binary data to a Base64url string.

func ToHex 

func ToHex(arg0 Expr) Expr

ToHex Converts binary data to its hexadecimal string representation.

func ToIso8601 

func ToIso8601(expr Expr) Expr

ToIso8601 Converts a datetime to an ISO 8601 string format.

func ToMicroseconds added in v1.2.152 

func ToMicroseconds(arg0 Expr) Expr

ToMicroseconds Converts a duration to microseconds.

func ToMilliseconds added in v1.2.152 

func ToMilliseconds(arg0 Expr) Expr

ToMilliseconds Converts a duration to milliseconds.

func ToUnixtime 

func ToUnixtime(arg0 Expr) Expr

ToUnixtime Converts a timestamp to Unix timestamp (seconds since epoch).

func ToUtf8 

func ToUtf8(arg0 Expr) Expr

ToUtf8 Encodes a string to UTF-8 binary data.

func TokenSetRatio 

func TokenSetRatio(a, b Expr) Expr

TokenSetRatio Calculates the token set ratio similarity between two strings using fuzzy matching.

func TokenSortRatio 

func TokenSortRatio(a, b Expr) Expr

TokenSortRatio Calculates the token sort ratio similarity between two strings using fuzzy matching.

func TotalSeconds added in v1.2.152 

func TotalSeconds(delta Expr) Expr

TotalSeconds Returns the length of the input duration in seconds.

func Trail added in v1.2.152 

func Trail(arg0, arg1 Expr) Expr

Trail Returns the last N characters of the input string up to at most the length of string.

func Transform added in v1.2.152 

func Transform(arg0, arg1 Expr) Expr

Transform Applies a transformation function to each element in an array and returns a new array.

func Trim 

func Trim(expr Expr, optional ...Expr) Expr

Trim Removes whitespace from both ends of a string.

func Truncate 

func Truncate(arg0 Expr) Expr

Truncate Truncates a floating-point number to remove the decimal part.

func Try added in v1.2.152 

func Try(arg0 Expr) Expr

Try Attempts to execute an expression and handles any errors gracefully.

func Uint8 

func Uint8(value uint8) Expr

Uint8 creates a uint8 literal expression

func Uint16 

func Uint16(value uint16) Expr

Uint16 creates a uint16 literal expression

func Uint32 

func Uint32(value uint32) Expr

Uint32 creates a uint32 literal expression

func Uint64 

func Uint64(value uint64) Expr

Uint64 creates a uint64 literal expression

func UnidecodeNormalize added in v1.2.152 

func UnidecodeNormalize(a Expr) Expr

UnidecodeNormalize Normalizes Unicode characters to their closest ASCII equivalents with whitespace normalization.

func UnidecodeToAscii added in v1.2.152 

func UnidecodeToAscii(a Expr) Expr

UnidecodeToAscii Converts Unicode characters to their closest ASCII equivalents.

func Upper 

func Upper(expr Expr) Expr

Upper Converts a string to uppercase.

func UrlDecode added in v1.2.152 

func UrlDecode(arg0 Expr) Expr

UrlDecode Decodes URL-encoded characters in a string.

func UrlEncode added in v1.2.152 

func UrlEncode(arg0 Expr) Expr

UrlEncode URL-encodes special characters in a string.

func UrlExtractFragment added in v1.2.152 

func UrlExtractFragment(arg0 Expr) Expr

UrlExtractFragment Extracts the fragment portion (after #) from a URL.

func UrlExtractHost added in v1.2.152 

func UrlExtractHost(expr Expr) Expr

UrlExtractHost Returns the host from a URL.

func UrlExtractParameter added in v1.2.152 

func UrlExtractParameter(arg0, arg1 Expr) Expr

UrlExtractParameter Extracts the value of a specific query parameter from a URL.

func UrlExtractPath added in v1.2.152 

func UrlExtractPath(expr Expr) Expr

UrlExtractPath Returns the path from a URL.

func UrlExtractPort added in v1.2.152 

func UrlExtractPort(arg0 Expr) Expr

UrlExtractPort Extracts the port number from a URL.

func UrlExtractProtocol added in v1.2.152 

func UrlExtractProtocol(expr Expr) Expr

UrlExtractProtocol Returns the protocol from a URL.

func UrlExtractQuery added in v1.2.152 

func UrlExtractQuery(arg0 Expr) Expr

UrlExtractQuery Extracts the query string portion (after ?) from a URL.

func Utf8 

func Utf8(value string) Expr

Utf8 creates a UTF-8 string literal expression

func VectorToBinary added in v1.2.152 

func VectorToBinary(arg0, arg1 Expr) Expr

VectorToBinary Returns binary of vector.

func Week added in v1.2.152 

func Week(arg0 Expr) Expr

Week Extracts the week of the year from a timestamp.

func WeekOfYear added in v1.2.152 

func WeekOfYear(expr Expr) Expr

WeekOfYear Extracts the week of the year from a timestamp.

func WeibullCdf added in v1.2.152 

func WeibullCdf(arg0, arg1, arg2 Expr) Expr

WeibullCdf Compute the Weibull cdf with given parameters a, b: P(N <= value). The a and b parameters must be positive doubles and value must also be a double.

func WidthBucket added in v1.2.152 

func WidthBucket(operand, bound1, bound2, bucket_count Expr) Expr

WidthBucket Returns the bucket number for a value in a histogram with uniform bucket widths.

func WilsonIntervalLower added in v1.2.152 

func WilsonIntervalLower(arg0, arg1, arg2 Expr) Expr

WilsonIntervalLower Returns the lower bound of the Wilson score interval of a Bernoulli trial process at a confidence specified by the z-score z.

func WilsonIntervalUpper added in v1.2.152 

func WilsonIntervalUpper(arg0, arg1, arg2 Expr) Expr

WilsonIntervalUpper Returns the upper bound of the Wilson score interval of a Bernoulli trial process at a confidence specified by the z-score z.

func WordStem added in v1.2.152 

func WordStem(string Expr) Expr

WordStem Returns the stem of a word using stemming algorithms.

func Xxhash64 added in v1.2.152 

func Xxhash64(arg0 Expr) Expr

Xxhash64 Computes a 64-bit XXHash of binary data.

func Year 

func Year(expr Expr) Expr

Year Extracts the year from a timestamp.

func YearOfWeek added in v1.2.152 

func YearOfWeek(arg0 Expr) Expr

YearOfWeek Extracts the year of the ISO week from a date.

func Yow added in v1.2.152 

func Yow(arg0 Expr) Expr

Yow Extracts the year of the ISO week from a date.

func ZiSplitPart 

func ZiSplitPart(arg0, arg1, arg2 Expr) Expr

ZiSplitPart Splits a string by delimiter and returns the part at the specified zero-based index.

func Zip added in v1.2.152 

func Zip(arg0, arg1 Expr) Expr

Zip Combines two lists element-wise into a list of paired structures.

func ZipWith added in v1.2.152 

func ZipWith(arg0, arg1, arg2 Expr) Expr

ZipWith Combines two lists element-wise using a callback function to transform paired elements.

type ExprI 

type ExprI interface {
	// String representation
	String() string
	// contains filtered or unexported methods
}

type GetAttributeExpr 

type GetAttributeExpr struct {
	Parent    Expr
	Attribute string
}

GetAttributeExpr represents field access like arr.length

func (*GetAttributeExpr) Add 

func (e *GetAttributeExpr) Add(other Expr) Expr

Implement Expr interface for GetAttributeExpr

func (*GetAttributeExpr) And 

func (e *GetAttributeExpr) And(other Expr) Expr

func (*GetAttributeExpr) Apply added in v1.2.95 

func (e *GetAttributeExpr) Apply(args ...Expr) Expr

func (*GetAttributeExpr) As 

func (e *GetAttributeExpr) As(alias string) Expr

func (*GetAttributeExpr) Attr 

func (e *GetAttributeExpr) Attr(attribute string) Expr

func (*GetAttributeExpr) Div 

func (e *GetAttributeExpr) Div(other Expr) Expr

func (*GetAttributeExpr) Eq 

func (e *GetAttributeExpr) Eq(other Expr) Expr

func (*GetAttributeExpr) Ge 

func (e *GetAttributeExpr) Ge(other Expr) Expr

func (*GetAttributeExpr) Gt 

func (e *GetAttributeExpr) Gt(other Expr) Expr

func (*GetAttributeExpr) IsNotNull 

func (e *GetAttributeExpr) IsNotNull() Expr

func (*GetAttributeExpr) IsNull 

func (e *GetAttributeExpr) IsNull() Expr

func (*GetAttributeExpr) Le 

func (e *GetAttributeExpr) Le(other Expr) Expr

func (*GetAttributeExpr) Lt 

func (e *GetAttributeExpr) Lt(other Expr) Expr

func (*GetAttributeExpr) Mul 

func (e *GetAttributeExpr) Mul(other Expr) Expr

func (*GetAttributeExpr) Ne 

func (e *GetAttributeExpr) Ne(other Expr) Expr

func (*GetAttributeExpr) Not 

func (e *GetAttributeExpr) Not() Expr

func (*GetAttributeExpr) Or 

func (e *GetAttributeExpr) Or(other Expr) Expr

func (*GetAttributeExpr) String 

func (e *GetAttributeExpr) String() string

func (*GetAttributeExpr) Sub 

func (e *GetAttributeExpr) Sub(other Expr) Expr

type IdentifierExpr 

type IdentifierExpr struct {
	Expr
	Name string
}

IdentifierExpr represents an identifier (variable name, column name, etc.)

func (*IdentifierExpr) Add 

func (e *IdentifierExpr) Add(other Expr) Expr

Implement Expr interface for IdentifierExpr

func (*IdentifierExpr) And 

func (e *IdentifierExpr) And(other Expr) Expr

func (*IdentifierExpr) Apply added in v1.2.95 

func (e *IdentifierExpr) Apply(args ...Expr) Expr

func (*IdentifierExpr) As 

func (e *IdentifierExpr) As(alias string) Expr

func (*IdentifierExpr) Attr 

func (e *IdentifierExpr) Attr(attribute string) Expr

func (*IdentifierExpr) Div 

func (e *IdentifierExpr) Div(other Expr) Expr

func (*IdentifierExpr) Eq 

func (e *IdentifierExpr) Eq(other Expr) Expr

func (*IdentifierExpr) Ge 

func (e *IdentifierExpr) Ge(other Expr) Expr

func (*IdentifierExpr) Gt 

func (e *IdentifierExpr) Gt(other Expr) Expr

func (*IdentifierExpr) IsNotNull 

func (e *IdentifierExpr) IsNotNull() Expr

func (*IdentifierExpr) IsNull 

func (e *IdentifierExpr) IsNull() Expr

func (*IdentifierExpr) Le 

func (e *IdentifierExpr) Le(other Expr) Expr

func (*IdentifierExpr) Lt 

func (e *IdentifierExpr) Lt(other Expr) Expr

func (*IdentifierExpr) Mul 

func (e *IdentifierExpr) Mul(other Expr) Expr

func (*IdentifierExpr) Ne 

func (e *IdentifierExpr) Ne(other Expr) Expr

func (*IdentifierExpr) Not 

func (e *IdentifierExpr) Not() Expr

func (*IdentifierExpr) Or 

func (e *IdentifierExpr) Or(other Expr) Expr

func (*IdentifierExpr) String 

func (e *IdentifierExpr) String() string

func (*IdentifierExpr) Sub 

func (e *IdentifierExpr) Sub(other Expr) Expr

type LiteralExpr 

type LiteralExpr struct {
	Expr
	ScalarValue         *arrowv1.ScalarValue
	IsArrowScalarObject bool
}

LiteralExpr represents a literal value using Arrow scalar values

func (*LiteralExpr) Add 

func (e *LiteralExpr) Add(other Expr) Expr

Implement Expr interface for LiteralExpr

func (*LiteralExpr) And 

func (e *LiteralExpr) And(other Expr) Expr

func (*LiteralExpr) Apply added in v1.2.95 

func (e *LiteralExpr) Apply(args ...Expr) Expr

func (*LiteralExpr) As 

func (e *LiteralExpr) As(alias string) Expr

func (*LiteralExpr) Attr 

func (e *LiteralExpr) Attr(attribute string) Expr

func (*LiteralExpr) Div 

func (e *LiteralExpr) Div(other Expr) Expr

func (*LiteralExpr) Eq 

func (e *LiteralExpr) Eq(other Expr) Expr

func (*LiteralExpr) Ge 

func (e *LiteralExpr) Ge(other Expr) Expr

func (*LiteralExpr) Gt 

func (e *LiteralExpr) Gt(other Expr) Expr

func (*LiteralExpr) IsNotNull 

func (e *LiteralExpr) IsNotNull() Expr

func (*LiteralExpr) IsNull 

func (e *LiteralExpr) IsNull() Expr

func (*LiteralExpr) Le 

func (e *LiteralExpr) Le(other Expr) Expr

func (*LiteralExpr) Lt 

func (e *LiteralExpr) Lt(other Expr) Expr

func (*LiteralExpr) Mul 

func (e *LiteralExpr) Mul(other Expr) Expr

func (*LiteralExpr) Ne 

func (e *LiteralExpr) Ne(other Expr) Expr

func (*LiteralExpr) Not 

func (e *LiteralExpr) Not() Expr

func (*LiteralExpr) Or 

func (e *LiteralExpr) Or(other Expr) Expr

func (*LiteralExpr) String 

func (e *LiteralExpr) String() string

func (*LiteralExpr) Sub 

func (e *LiteralExpr) Sub(other Expr) Expr

type StructField added in v1.2.148 

type StructField struct {
	Name       string
	Expression Expr
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.