PyStarburst API#
- Column
- Column methods
CaseExpr
Column
Column.alias()
Column.as_()
Column.asc()
Column.asc_nulls_first()
Column.asc_nulls_last()
Column.astype()
Column.between()
Column.bitand()
Column.bitor()
Column.bitwiseAND()
Column.bitwiseOR()
Column.bitwiseXOR()
Column.bitxor()
Column.cast()
Column.contains()
Column.desc()
Column.desc_nulls_first()
Column.desc_nulls_last()
Column.ends_with()
Column.endswith()
Column.eqNullSafe()
Column.equal_nan()
Column.equal_null()
Column.ilike()
Column.in_()
Column.isNotNull()
Column.isNull()
Column.is_not_null()
Column.is_null()
Column.isin()
Column.like()
Column.name()
Column.over()
Column.regexp()
Column.regexp_like()
Column.rlike()
Column.starts_with()
Column.startswith()
Column.substr()
Column.substring()
Column.try_cast()
- Column methods
- Dataframe
- Dataframe methods
DataFrame
DataFrame.agg()
DataFrame.alias()
DataFrame.approxQuantile()
DataFrame.approx_quantile()
DataFrame.col()
DataFrame.colRegex()
DataFrame.col_regex()
DataFrame.collect()
DataFrame.columns
DataFrame.corr()
DataFrame.count()
DataFrame.cov()
DataFrame.createOrReplaceView()
DataFrame.create_or_replace_view()
DataFrame.crossJoin()
DataFrame.cross_join()
DataFrame.cube()
DataFrame.describe()
DataFrame.distinct()
DataFrame.drop()
DataFrame.dropDuplicates()
DataFrame.drop_duplicates()
DataFrame.dropna()
DataFrame.exceptAll()
DataFrame.except_()
DataFrame.explain()
DataFrame.explode()
DataFrame.explode_outer()
DataFrame.fillna()
DataFrame.filter()
DataFrame.first()
DataFrame.groupBy()
DataFrame.groupByGroupingSets()
DataFrame.group_by()
DataFrame.group_by_grouping_sets()
DataFrame.head()
DataFrame.inline()
DataFrame.inline_outer()
DataFrame.intersect()
DataFrame.intersectAll()
DataFrame.intersect_all()
DataFrame.isEmpty()
DataFrame.is_cached
DataFrame.is_empty()
DataFrame.join()
DataFrame.limit()
DataFrame.melt()
DataFrame.minus()
DataFrame.na
DataFrame.orderBy()
DataFrame.order_by()
DataFrame.pivot()
DataFrame.posexplode()
DataFrame.posexplode_outer()
DataFrame.queries
DataFrame.randomSplit()
DataFrame.random_split()
DataFrame.rename()
DataFrame.replace()
DataFrame.rollup()
DataFrame.sample()
DataFrame.sampleBy()
DataFrame.sample_by()
DataFrame.schema
DataFrame.select()
DataFrame.selectExpr()
DataFrame.select_expr()
DataFrame.show()
DataFrame.sort()
DataFrame.stack()
DataFrame.stat
DataFrame.subtract()
DataFrame.summary()
DataFrame.take()
DataFrame.to()
DataFrame.toDF()
DataFrame.toLocalIterator()
DataFrame.to_df()
DataFrame.to_local_iterator()
DataFrame.to_pandas()
DataFrame.transform()
DataFrame.union()
DataFrame.unionAll()
DataFrame.unionAllByName()
DataFrame.unionByName()
DataFrame.union_all()
DataFrame.union_all_by_name()
DataFrame.union_by_name()
DataFrame.unpivot()
DataFrame.where()
DataFrame.withColumn()
DataFrame.withColumnRenamed()
DataFrame.withColumns()
DataFrame.withColumnsRenamed()
DataFrame.with_column()
DataFrame.with_column_renamed()
DataFrame.with_columns()
DataFrame.with_columns_renamed()
DataFrame.write
- Dataframe methods
- Dataframe functions
- Dataframe methods
abs()
acos()
acosh()
add_months()
aggregate()
all_match()
any_match()
any_value()
approx_count_distinct()
approx_distinct()
approx_percentile()
approx_percentile_accumulate()
approx_percentile_combine()
approx_percentile_estimate()
array_agg()
array_append()
array_cat()
array_compact()
array_construct()
array_contains()
array_distinct()
array_except()
array_flatten()
array_insert()
array_intersect()
array_intersection()
array_join()
array_max()
array_min()
array_position()
array_prepend()
array_remove()
array_repeat()
array_size()
array_slice()
array_sort()
array_to_string()
array_union()
arrays_overlap()
arrays_zip()
asc()
asc_nulls_first()
asc_nulls_last()
ascii()
asin()
assert_true()
atan()
atan2()
avg()
base64()
bit_length()
bitand()
bitnot()
bitor()
bitshiftleft()
bitshiftright()
bitwiseNOT()
bitwise_not()
bitxor()
builtin()
call_builtin()
call_function()
call_table_function()
cast()
cbrt()
ceil()
coalesce()
codepoint()
col()
collectList()
collectSet()
collect_list()
collect_set()
column()
concat()
concat_ws()
contains()
conv()
convert_timezone()
corr()
cos()
cosh()
cot()
count()
countDistinct()
count_distinct()
covar_pop()
covar_samp()
crc32()
create_map()
csc()
cume_dist()
current_catalog()
current_date()
current_groups()
current_schema()
current_time()
current_timestamp()
current_timezone()
current_user()
date_add()
date_format()
date_sub()
date_trunc()
dateadd()
datediff()
day()
dayofmonth()
dayofweek()
dayofyear()
degrees()
dense_rank()
desc()
desc_nulls_first()
desc_nulls_last()
div0()
element_at()
ends_with()
endswith()
equal_nan()
exists()
exp()
expm1()
expr()
fail()
filter()
first_value()
flatten()
floor()
forall()
format_string()
from_json()
from_unixtime()
from_utc_timestamp()
function()
get()
get_json_object()
greatest()
grouping()
hash()
hex()
hour()
hypot()
iff()
in_()
initcap()
instr()
is_nan()
is_not_null()
is_null()
isnan()
isnull()
json_array_length()
json_extract()
json_parse()
json_tuple()
kurtosis()
lag()
last_day()
last_value()
lead()
least()
length()
levenshtein()
levenshtein_distance()
listagg()
lit()
locate()
log()
log10()
log1p()
log2()
lower()
lpad()
ltrim()
make_date()
map_concat()
map_entries()
map_filter()
map_from_arrays()
map_from_entries()
map_keys()
map_values()
map_zip_with()
max()
max_by()
md5()
mean()
min()
min_by()
minute()
mode()
month()
negate()
not_()
nth_value()
ntile()
octet_length()
overlay()
parse_json()
percent_rank()
percentile_approx()
pmod()
pow()
power()
product()
quarter()
radians()
raise_error()
random()
rank()
reduce()
regexp_count()
regexp_extract()
regexp_replace()
repeat()
replace()
reverse()
round()
row_number()
rpad()
rtrim()
sec()
second()
sequence()
sha1()
sha2()
shuffle()
signum()
sin()
sinh()
size()
skew()
skewness()
sort_array()
soundex()
split()
sql_expr()
sqrt()
starts_with()
startswith()
stddev()
stddev_pop()
stddev_samp()
strpos()
struct()
substr()
substring()
substring_index()
sum()
sumDistinct()
sum_distinct()
table_function()
tan()
tanh()
timestamp_seconds()
to_date()
to_hex()
to_json()
to_time()
to_timestamp()
to_utc_timestamp()
transform()
transform_keys()
transform_values()
translate()
trim()
trunc()
try_cast()
typeof()
unbase64()
unhex()
unix_timestamp()
upper()
var_pop()
var_samp()
variance()
week_of_year()
weekofyear()
when()
when_matched()
when_not_matched()
xxhash64()
year()
zip_with()
- Dataframe methods
- Dataframe grouping functions
- Dataframe grouping methods
GroupingSets
RelationalGroupedDataFrame
RelationalGroupedDataFrame.agg()
RelationalGroupedDataFrame.avg()
RelationalGroupedDataFrame.builtin()
RelationalGroupedDataFrame.count()
RelationalGroupedDataFrame.function()
RelationalGroupedDataFrame.max()
RelationalGroupedDataFrame.mean()
RelationalGroupedDataFrame.min()
RelationalGroupedDataFrame.sum()
- Dataframe grouping methods
- Dataframe NA functions
- Dataframe stat functions
- Dataframe write functions
- Query history
- Row
- Session
- Session
SchemaDiscoveryResult
Session
Session.SessionBuilder
Session.builder
Session.cache_results()
Session.cancel_all()
Session.close()
Session.createDataFrame()
Session.create_dataframe()
Session.discover()
Session.get_current_catalog()
Session.get_current_roles()
Session.get_current_schema()
Session.get_fully_qualified_current_schema()
Session.query_history()
Session.range()
Session.set_role()
Session.sql()
Session.table()
Session.table_function()
Session.use()
- Session
- Table
- Table function
- Window function
- Window function
Window
Window.CURRENT_ROW
Window.UNBOUNDED_FOLLOWING
Window.UNBOUNDED_PRECEDING
Window.currentRow
Window.orderBy()
Window.order_by()
Window.partitionBy()
Window.partition_by()
Window.rangeBetween()
Window.range_between()
Window.rowsBetween()
Window.rows_between()
Window.unboundedFollowing
Window.unboundedPreceding
WindowSpec
- Window function