expr

func DataFrame ¶

func DataFrame(name string) DataFrameExpr

DataFrame creates a dataframe reference for aggregations

func Abs ¶

func Abs(x Expr) Expr

Abs calculates absolute value

func And ¶

func And(a, b Expr) Expr

And performs logical AND

func ArrayAverage ¶

func ArrayAverage(array Expr) Expr

ArrayAverage calculates average of numeric array

func ArrayConstructor ¶

func ArrayConstructor(elements ...Expr) Expr

ArrayConstructor creates array from elements

func ArrayDistinct ¶

func ArrayDistinct(array Expr) Expr

ArrayDistinct returns unique elements from array

func ArrayFrequency ¶

func ArrayFrequency(array Expr) Expr

ArrayFrequency returns frequency map of array elements

func ArrayJoin ¶

func ArrayJoin(array, separator Expr) Expr

ArrayJoin joins array elements with separator

func ArrayMax ¶

func ArrayMax(array Expr) Expr

ArrayMax returns maximum element from array

func ArrayMedian ¶

func ArrayMedian(array Expr) Expr

ArrayMedian calculates median of numeric array

func ArrayMin ¶

func ArrayMin(array Expr) Expr

ArrayMin returns minimum element from array

func ArrayMode ¶

func ArrayMode(array Expr, mode ...Expr) Expr

ArrayMode calculates mode of array

func ArraySort ¶

func ArraySort(array Expr) Expr

ArraySort sorts array in ascending order

func ArraySortDesc ¶

func ArraySortDesc(array Expr) Expr

ArraySortDesc sorts array in descending order

func ArrayStddev ¶

func ArrayStddev(array, isSample Expr) Expr

ArrayStddev calculates standard deviation of array

func ArraySum ¶

func ArraySum(array Expr) Expr

ArraySum calculates sum of numeric array

func BankersRound ¶

func BankersRound(x Expr, decimals ...Expr) Expr

BankersRound rounds using banker's rounding (round half to even)

func Binary ¶

func Binary(value []byte) Expr

Binary creates a binary literal expression

func Bool ¶

func Bool(value bool) Expr

Bool creates a boolean literal expression

func BoostRegexpFindall ¶

func BoostRegexpFindall(str, pattern Expr) Expr

BoostRegexpFindall finds all matches of regular expression

func BytesToUtf8 ¶ added in v1.2.139

func BytesToUtf8(bytes Expr) Expr

BytesToUtf8 converts from binary data to UTF-8 string (same as chalkpy bytes_to_string(..., encoding='utf-8'))

func Cardinality ¶

func Cardinality(array Expr) Expr

Cardinality returns length of array

func Cast ¶ added in v1.2.139

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

Cast converts a value to a target type

func Ceiling ¶

func Ceiling(x Expr) Expr

Ceiling rounds up to nearest integer

func ChalkNow ¶ added in v1.2.88

func ChalkNow() Expr

func ChalkWindow ¶ added in v1.2.109

func ChalkWindow() Expr

func Coalesce ¶

func Coalesce(values ...Expr) Expr

Coalesce returns first non-null value

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 Expr, rest ...Expr) Expr

Concat concatenates strings or arrays

func Contains ¶

func Contains(array, element Expr) Expr

Contains checks if array contains element

func Cos ¶

func Cos(x Expr) Expr

Cos calculates cosine

func CurrentDate ¶

func CurrentDate() Expr

CurrentDate returns 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 DateTrunc ¶

func DateTrunc(unit, timestamp Expr) Expr

DateTrunc truncates timestamp to specified unit

func DayOfMonth ¶

func DayOfMonth(dateTime Expr) Expr

DayOfMonth extracts day of month from timestamp or date

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 ElementAt ¶

func ElementAt(array, index Expr) Expr

ElementAt returns element at index (1-indexed)

func EndsWith ¶

func EndsWith(str, suffix Expr) Expr

EndsWith checks if string ends with suffix

func Eq ¶

func Eq(a, b Expr) Expr

Eq performs equality comparison

func Fail ¶

func Fail(message Expr) Expr

Fail throws an error with message

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(x Expr) Expr

Floor rounds down to nearest integer

func FormatDatetime ¶

func FormatDatetime(timestamp, format Expr) Expr

FormatDatetime formats timestamp as string

func FromBase ¶

func FromBase(str, base Expr) Expr

FromBase converts string from specified base to integer

func FromBigEndian32 ¶

func FromBigEndian32(data Expr) Expr

FromBigEndian32 converts binary data to int32 using big-endian byte order

func FromBigEndian64 ¶

func FromBigEndian64(data Expr) Expr

FromBigEndian64 converts binary data to int64 using big-endian byte order

func FromIso8601Timestamp ¶

func FromIso8601Timestamp(str Expr) Expr

FromIso8601Timestamp parses ISO8601 timestamp string

func FromUnixSeconds ¶

func FromUnixSeconds(seconds Expr) Expr

FromUnixSeconds converts Unix timestamp to timestamp

func FromUtf8 ¶

func FromUtf8(data Expr) Expr

FromUtf8 converts to binary data from UTF-8 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 GetJsonValue ¶

func GetJsonValue(json Expr, path string) Expr

GetJsonValue extracts value from JSON

func Gt ¶

func Gt(a, b Expr) Expr

Gt performs greater than comparison

func Gte ¶

func Gte(a, b Expr) Expr

Gte performs greater than or equal comparison

func Hour ¶

func Hour(timestamp Expr) Expr

Hour extracts hour from timestamp

func Identifier ¶

func Identifier(name string) Expr

Identifier creates an identifier expression

func IfElse ¶

func IfElse(condition, trueValue, falseValue Expr) Expr

IfElse conditional expression

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 IsNan ¶

func IsNan(x Expr) Expr

IsNan checks if value is NaN

func JaccardSimilarity ¶

func JaccardSimilarity(left, right Expr) Expr

JaccardSimilarity calculates Jaccard similarity between two strings

func JaroWinklerDistance ¶

func JaroWinklerDistance(left, right, threshold Expr) Expr

JaroWinklerDistance calculates Jaro-Winkler distance

func Jsonify ¶ added in v1.2.139

func Jsonify(json Expr) Expr

Jsonify turns a value into a JSON string

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(timestamp Expr) Expr

LastDayOfMonth returns the last day of the month for given timestamp

func Length ¶

func Length(str Expr) Expr

Length returns the length of a string

func Like ¶

func Like(str, pattern Expr) Expr

Like performs SQL LIKE pattern matching

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 Log10 ¶

func Log10(x Expr) Expr

Log10 calculates base-10 logarithm

func Lower ¶

func Lower(str Expr) Expr

Lower converts string to lowercase

func Lt ¶

func Lt(a, b Expr) Expr

Lt performs less than comparison

func Lte ¶

func Lte(a, b Expr) Expr

Lte performs less than or equal comparison

func Ltrim ¶

func Ltrim(str Expr, chars ...Expr) Expr

Ltrim removes whitespace from left end of string

func MapContains ¶

func MapContains(mapExpr, predicate Expr) Expr

MapContains checks if map contains key matching predicate

func MapGet ¶

func MapGet(mapExpr, key Expr) Expr

MapGet gets value from map by key

func MapKeysByTopNValues ¶

func MapKeysByTopNValues(mapExpr, n Expr) Expr

MapKeysbyTopNValues returns keys with top N values from map

func Md5 ¶

func Md5(data Expr) Expr

Md5 calculates MD5 hash

func Minute ¶

func Minute(timestamp Expr) Expr

Minute extracts minute from timestamp

func Mod ¶

func Mod(a, b Expr) Expr

Mod calculates modulo

func Month ¶

func Month(dateTime Expr) Expr

Month extracts month from timestamp or date

func Nan ¶

func Nan() Expr

Nan returns NaN value

func Negate ¶

func Negate(x Expr) Expr

Negate negates a number

func Neq ¶

func Neq(a, b Expr) Expr

Neq performs inequality comparison

func Now ¶

func Now() Expr

Now returns current timestamp (convenience function)

func Null ¶

func Null() Expr

Null creates a null literal expression

func ParseDatetime ¶

func ParseDatetime(dateStr, format Expr) Expr

ParseDatetime parses datetime string with format

func PartialRatio ¶

func PartialRatio(left, right Expr) Expr

PartialRatio calculates partial ratio similarity

func PythonElementAt ¶

func PythonElementAt(array, index Expr) Expr

PythonElementAt returns element at index (0-based for Python compatibility)

func Rand ¶ added in v1.2.140

func Rand() Expr

func RegexpLike ¶

func RegexpLike(str, pattern Expr) Expr

RegexpLike performs regular expression matching

func RegexpReplace ¶

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

RegexpReplace replaces text matching regular expression

func Replace ¶

func Replace(str, old, new Expr) Expr

Replace replaces all occurrences of old substring with new

func Reverse ¶

func Reverse(str Expr) Expr

Reverse reverses a string

func Round ¶

func Round(x Expr, decimals ...Expr) Expr

Round rounds to nearest integer or specified decimal places

func Rtrim ¶

func Rtrim(str Expr, chars ...Expr) Expr

Rtrim removes whitespace from right end of string

func ScalarMax ¶

func ScalarMax(a, b Expr) Expr

ScalarMax returns maximum of two values

func ScalarMin ¶

func ScalarMin(a, b Expr) Expr

ScalarMin returns minimum of two values

func Second ¶

func Second(timestamp Expr) Expr

Second extracts second from timestamp

func SequenceMatcherRatio ¶

func SequenceMatcherRatio(left, right Expr) Expr

SequenceMatcherRatio calculates similarity ratio between two strings

func Sha1 ¶

func Sha1(data Expr) Expr

Sha1 calculates SHA-1 hash

func Sha256 ¶

func Sha256(data Expr) Expr

Sha256 calculates SHA-256 hash

func Sha512 ¶

func Sha512(data Expr) Expr

Sha512 calculates SHA-512 hash

func Sin ¶

func Sin(x Expr) Expr

Sin calculates sine

func Slice ¶

func Slice(array, start, length Expr) Expr

Slice extracts slice from array

func Split ¶

func Split(str, delimiter Expr, maxSplit ...Expr) Expr

Split splits string by delimiter

func SpookyHashV232 ¶

func SpookyHashV232(data Expr) Expr

SpookyHashV232 calculates 32-bit SpookyHash

func SpookyHashV264 ¶

func SpookyHashV264(data Expr) Expr

SpookyHashV264 calculates 64-bit SpookyHash

func Sqrt ¶

func Sqrt(x Expr) Expr

Sqrt calculates square root

func StartsWith ¶

func StartsWith(str, prefix Expr) Expr

StartsWith checks if string starts with prefix

func String ¶

func String(value string) Expr

String is an alias for Utf8 for convenience

func StringFromTimestamp ¶

func StringFromTimestamp(timestamp Expr) Expr

StringFromTimestamp converts timestamp to ISO8601 string

func Strpos ¶

func Strpos(str, substr Expr) Expr

Strpos finds the position of substring in string (0-based)

func Strrpos ¶

func Strrpos(str, substr Expr) Expr

Strrpos finds the last position of substring in string (0-based)

func StructPack ¶ added in v1.2.140

func StructPack(fields map[string]Expr) Expr

func Substr ¶

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

Substr extracts substring

func Tan ¶

func Tan(x Expr) Expr

Tan calculates tangent

func Timestamp ¶

func Timestamp(value time.Time) Expr

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

func TimestampFromString ¶

func TimestampFromString(str Expr) Expr

TimestampFromString parses timestamp from ISO8601 string

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 ToHex ¶

func ToHex(data Expr) Expr

ToHex converts binary data to hexadecimal string representation

func ToIso8601 ¶

func ToIso8601(timestamp Expr) Expr

ToIso8601 converts timestamp to ISO8601 string

func ToUnixtime ¶

func ToUnixtime(timestamp Expr) Expr

ToUnixtime converts timestamp to Unix timestamp (seconds since epoch)

func ToUtf8 ¶

func ToUtf8(str Expr) Expr

ToUtf8 converts string to UTF-8 binary data

func TokenSetRatio ¶

func TokenSetRatio(left, right Expr) Expr

TokenSetRatio calculates token set ratio similarity

func TokenSortRatio ¶

func TokenSortRatio(left, right Expr) Expr

TokenSortRatio calculates token sort ratio similarity

func Trim ¶

func Trim(str Expr, chars ...Expr) Expr

Trim removes whitespace from both ends of string

func Truncate ¶

func Truncate(x Expr) Expr

Truncate truncates to integer part

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 Upper ¶

func Upper(str Expr) Expr

Upper converts string to uppercase

func Utf8 ¶

func Utf8(value string) Expr

Utf8 creates a UTF-8 string literal expression

func Year ¶

func Year(dateTime Expr) Expr

Year extracts year from timestamp or date

func ZiSplitPart ¶

func ZiSplitPart(str, delimiter, index Expr) Expr

ZiSplitPart splits string and returns part at index (0-based)