Returns a [Column] based on the given column name.

Concatenates multiple input string columns together into a single string column, using the given separator

Convert a number in a string column from one base to another.

Converts the timestamp without time zone sourceTs from the sourceTz time zone to targetTz.

Returns a new Column for distinct count of col or cols

Returns a count-min sketch of a column with the given esp, confidence and seed.

Creates a global temporary view with this [DataFrame].

Creates a local temporary view with this [DataFrame]

Create a multi-dimensional cube for the current [DataFrame] using the specified columns, so we can run aggregations on them.

Returns 0

Returns a sort expression based on the descending order of the given column name, and null values appear before non-null values.

Returns a sort expression based on the descending order of the given column name, and null values appear after non-null values.

Return a new [DataFrame] with duplicate rows removed, optionally only considering certain columns, within watermark. This only works with streaming [

TODO! this should probably be an enum

Create an empty StructType

!TODO i don't really like the return values on this

Parses the expression string into the column that it represents

Replace null values, alias for `df.na().fill()`.

Returns the first value in a group.

Returns the first value of col for a group of rows.

Formats the arguments in printf-style and returns the result as a string column

Finding frequent items for columns, possibly with false positives.

Used for creating columns from a [spark::Expression]

Create a new Spark Session from a [Config] object

Parses a column containing a CSV string to a row with the specific schema. Returns null in the case of an unparseable string

Wraps an external error in an `SparkError`.

Parses a column containing a JSON string to a row with the specific schema. Returns null in the case of an unparseable string

Converts the number of seconds from unix epoch (1970-01-01 00:00:00 UTC) to a string representing the timestamp of that moment in the current system t

Get the function with the specified name.

Get the table or view with the specified name.

Specifies some hint on the current [DataFrame].

Returns the updatable binary representation of the Datasketches HllSketch configured with lgConfigK arg.

Returns the updatable binary representation of the Datasketches HllSketch, generated by merging previously created Datasketches HllSketch instances vi

Inserts the content of the [DataFrame] to the specified table. It requires that the schema of the [DataFrame] is the same as the schema of the target

Interrupt all operations of this session currently running on the connected server.

Interrupt an operation of this session with the given operationId.

Interrupt all operations of this session with the given operation tag.

Return a new [DataFrame] containing rows in both this [DataFrame] and another [DataFrame] while preserving duplicates.

Returns `true` if the `collect()` and `take()` methods can be run locally (without any Spark executors).

A filter expression that evaluates to true is the expression is NOT null

A filter expression that evaluates to true is the expression is null

Returns `true` if this [DataFrame] contains one or more sources that continuously return data as it arrives.

Creates a new row for a json column according to the given field names.

Returns the value that os offset rows before the current row, and default is there is less than offset rows before the current row

Returns the last value in a group.

Returns the last value of col for a group of rows.

Returns the value that os offset rows after the current row, and default is there is less than offset rows after the current row

Returns a list of databases in this session

Returns a list of functions registered in the specified database.

Returns a list of tables/views in the specific database