Functions

org.apache.spark.sql.functions => com.snowflake.snowpark.functions

Spark	SnowPark	Notes
abs(e: Column): Column	abs
array(String colName, Seq[String] colNames)	array_construct*
array_agg(e: Column): Column	array_agg
acos(e: Column): Column	acos
add_months(startDate: Column, numMonths: Int): Column	add_months
approx_count_distinct(columnName: String, rsd: Double): Column	N/A
approx_count_distinct(e: Column, rsd: Double): Column	N/A
approx_count_distinct(columnName: String): Column	aprox_count_disctinct*
approx_count_distinct(e: Column): Column	approx_count_distinct
array(Column* cols)	array_construct*
array(Seq[Column] cols)	array_construct*
array(String colName, String* colNames)	array_construct*
ascii(e: Column): Column	ascii
asin(e: Column): Column	asin
atan(e: Column): Column	atan
atan2(l: Column, r: Column): Column	atan2
avg(e: Column): Column	avg
callUDF(udfName: String, cols: Column*): Column	callUDF(udfName: String, cols: Any*): Column
ceil(columnName: String): Column	ceil*
ceil(e: Column): Column	ceil
coalesce(e: Column*): Column	coalesce
coalesce(Seq[Column] e)	**
col(colName: String): Column	col
collect_list(Column e)	array_agg ( col: Column ) : Column
collect_list(String columnName)	**
column(String colName)	column ( colName: String ) : Column
corr(columnName1: String, columnName2: String): Column	corr*
corr(column1: Column, column2: Column): Column	corr
cos(e: Column): Column	cos
concat(exprs: Column*): Column	concat *
cosh(e: Column): Column	cosh
count(columnName: String): TypedColumn[Any, Long]	count*
count(e: Column): Column	count
countDistinct(expr: Column, exprs: Column*): Column	count_distinct(expr: Column, exprs: Column*)
countDistinct(expr:Column, exprs: Seq[Column])	count_distinct*
countDistrinct(column:String, exprs:Seq[String])	count_distinct*
countDistinct(columnName: String, columnNames: String*): Column	count_distinct*
covar_pop(columnName1: String, columnName2: String): Column	covar_pop*
covar_pop(column1: Column, column2: Column): Column	covar_pop
covar_samp(columnName1: String, columnName2: String): Column	covar_samp*
covar_samp(column1: Column, column2: Column): Column	covar_samp
cume_dist(): Column	cume_dist
current_date(): Column	current_date
current_timestamp(): Column	current_timestamp
datediff(end: Column, start: Column): Column	datediff***
dayofmonth(e: Column): Column	dayofmonth
dayofyear(e: Column): Column	dayofyear
degrees(e: Column): Column	degrees
desc(String columnName)	*
concat_ws(sep: String, exprs: Column*): Column	concat_ws **
exp(e: Column): Column	exp
explode(e: Column)	**
expr(String expr): Column	sqlExpr ( sqlText: String ) : Column
factorial(e: Column): Column	factorial
floor(e: Column): Column	floor
greatest(exprs: Column*): Column	greatest
grouping(columnName: String): Column	grouping*
grouping(e: Column): Column	grouping
grouping_id(colName: String, colNames: String*): Column	grouping_id
grouping_id(cols: Column*): Column	grouping_id
hash(cols: Column*): Column	hash
hour(e: Column): Column	hour
initcap(e: Column): Column	initcap
kurtosis(columnName: String): Column	kurtosis*
kurtosis(e: Column): Column	kurtosis
last_day(e: Column): Column	last_day
least(exprs: Column*): Column	least
length(e: Column): Column	length
lit(literal: Any): Column	lit
log(base: Double, columnName: String): Column	log*
lower(e: Column): Column	lower
lpad(str: Column, len: Int, pad: String): Column	lpad*
ltrim(e: Column): Column	ltrim
ltrim(e: Column, trimString: String): Column	ltrim
max(columnName: String): Column	max*
max(e: Column): Column	max
md5(e: Column): Column	md5
mean(columnName: String): Column	mean*
mean(e: Column): Column	mean
min(columnName: String): Column	min*
min(e: Column): Column	min
minute(e: Column): Column	minute
month(e: Column): Column	month
next_day(date: Column, dayOfWeek: String): Column	next_day*
not(e: Column): Column	not
pow(l: Column, r: Column): Column	pow
quarter(e: Column): Column	quarter
radians(e: Column): Column	radians
rand(): Column	N/A
rand(seed: Long): Column	N/A
rank(): Column	rank
repeat(str: Column, n: Int): Column	repeat *
round(e: Column, scale: Int): Column	round *
round(e: Column): Column	round
row_number(): Column	row_number
rpad(str: Column, len: Int, pad: String): Column	rpad*
rtrim(e: Column): Column	rtrim
rtrim(e: Column, trimString: String): Column	rtrim
second(e: Column): Column	second
sha1(e: Column): Column	sha1
sha2(e: Column, numBits: Int): Column	sha2
sin(e: Column): Column	sin
sinh(e: Column): Column	sinh
size(e:Column): Column	array_size*
soundex(e: Column): Column	soundex
split(str: Column, pattern: String): Column	split *
sqrt(e: Column): Column	sqrt
stddev(e: Column): Column	stddev
stddev_pop(e: Column): Column	stddev_pop
stddev_samp(e: Column): Column	stddev_samp
substring(str: Column, pos: Int, len: Int): Column	substring *
sum(e: Column): Column	sum
sumDistinct(e: Column): Column	sum_distinct *
tan(e: Column): Column	tan
tanh(e: Column): Column	tanh
to_date(e: Column): Column	to_date
translate(src: Column, matchingString: String, replaceString: String): Column	translate*
trim(e: Column): Column	trim**
trim(e: Column, trimString: String): Column	trim
trunc(date: Column, format: String): Column	trunc *
upper(e: Column): Column	upper
var_pop(e: Column): Column	var_pop
var_samp(e: Column): Column	var_samp
variance(e: Column): Column	variance
weekofyear(e: Column): Column	weekofyear
when(condition: Column, value: Any): Column	when
window(timeColumn: Column, windowDuration: String): Column	N/A
window(timeColumn: Column, windowDuration: String, slideDuration: String): Column	N/A
window(timeColumn: Column, windowDuration: String, slideDuration: String, startTime: String): Column	N/A
year(e: Column): Column	year