PyStarburst API#
- Column
- Column methods
CaseExprColumnColumn.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
DataFrameDataFrame.agg()DataFrame.alias()DataFrame.approxQuantile()DataFrame.approx_quantile()DataFrame.col()DataFrame.colRegex()DataFrame.col_regex()DataFrame.collect()DataFrame.columnsDataFrame.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_cachedDataFrame.is_empty()DataFrame.join()DataFrame.limit()DataFrame.melt()DataFrame.minus()DataFrame.naDataFrame.orderBy()DataFrame.order_by()DataFrame.pivot()DataFrame.posexplode()DataFrame.posexplode_outer()DataFrame.queriesDataFrame.randomSplit()DataFrame.random_split()DataFrame.rename()DataFrame.replace()DataFrame.rollup()DataFrame.sample()DataFrame.sampleBy()DataFrame.sample_by()DataFrame.schemaDataFrame.select()DataFrame.selectExpr()DataFrame.select_expr()DataFrame.show()DataFrame.sort()DataFrame.stack()DataFrame.statDataFrame.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
GroupingSetsRelationalGroupedDataFrameRelationalGroupedDataFrame.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
SchemaDiscoveryResultSessionSession.SessionBuilderSession.builderSession.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
WindowWindow.CURRENT_ROWWindow.UNBOUNDED_FOLLOWINGWindow.UNBOUNDED_PRECEDINGWindow.currentRowWindow.orderBy()Window.order_by()Window.partitionBy()Window.partition_by()Window.rangeBetween()Window.range_between()Window.rowsBetween()Window.rows_between()Window.unboundedFollowingWindow.unboundedPreceding
WindowSpec
- Window function