Showing content from https://api-docs.databricks.com/scala/spark/latest/org/apache/spark/sql/functions$.html below:
Databricks Scala Spark API - org.apache.spark.sql.functions
object functions
î· î
Ordering
- Grouped
- Alphabetic
- By Inheritance
Inherited
- functions
- AnyRef
- Any
Value Members
- î
final def !=(arg0: Any): Boolean
- î
final def ##(): Int
- î
final def ==(arg0: Any): Boolean
- î
def abs(e: Column): Column
- î
def acos(columnName: String): Column
- î
def acos(e: Column): Column
- î
def acosh(columnName: String): Column
- î
def acosh(e: Column): Column
- î
def add_months(startDate: Column, numMonths: Column): Column
- î
def add_months(startDate: Column, numMonths: Int): Column
- î
def aggregate(expr: Column, initialValue: Column, merge: (Column, Column) â Column): Column
- î
def aggregate(expr: Column, initialValue: Column, merge: (Column, Column) â Column, finish: (Column) â Column): Column
- î
def approx_count_distinct(columnName: String, rsd: Double): Column
- î
def approx_count_distinct(e: Column, rsd: Double): Column
- î
def approx_count_distinct(columnName: String): Column
- î
def approx_count_distinct(e: Column): Column
- î
def array(colName: String, colNames: String*): Column
- î
def array(cols: Column*): Column
- î
def array_contains(column: Column, value: Any): Column
- î
def array_distinct(e: Column): Column
- î
def array_except(col1: Column, col2: Column): Column
- î
def array_intersect(col1: Column, col2: Column): Column
- î
def array_join(column: Column, delimiter: String): Column
- î
def array_join(column: Column, delimiter: String, nullReplacement: String): Column
- î
def array_max(e: Column): Column
- î
def array_min(e: Column): Column
- î
def array_position(column: Column, value: Any): Column
- î
def array_remove(column: Column, element: Any): Column
- î
def array_repeat(e: Column, count: Int): Column
- î
def array_repeat(left: Column, right: Column): Column
- î
def array_sort(e: Column): Column
- î
def array_union(col1: Column, col2: Column): Column
- î
def arrays_overlap(a1: Column, a2: Column): Column
- î
def arrays_zip(e: Column*): Column
- î
final def asInstanceOf[T0]: T0
- î
def asc(columnName: String): Column
- î
def asc_nulls_first(columnName: String): Column
- î
def asc_nulls_last(columnName: String): Column
- î
def ascii(e: Column): Column
- î
def asin(columnName: String): Column
- î
def asin(e: Column): Column
- î
def asinh(columnName: String): Column
- î
def asinh(e: Column): Column
- î
def assert_true(c: Column, e: Column): Column
- î
def assert_true(c: Column): Column
- î
def atan(columnName: String): Column
- î
def atan(e: Column): Column
- î
def atan2(yValue: Double, xName: String): Column
- î
def atan2(yValue: Double, x: Column): Column
- î
def atan2(yName: String, xValue: Double): Column
- î
def atan2(y: Column, xValue: Double): Column
- î
def atan2(yName: String, xName: String): Column
- î
def atan2(yName: String, x: Column): Column
- î
def atan2(y: Column, xName: String): Column
- î
def atan2(y: Column, x: Column): Column
- î
def atanh(columnName: String): Column
- î
def atanh(e: Column): Column
- î
def avg(columnName: String): Column
- î
def avg(e: Column): Column
- î
def base64(e: Column): Column
- î
def bin(columnName: String): Column
- î
def bin(e: Column): Column
- î
def bit_length(e: Column): Column
- î
def bitwise_not(e: Column): Column
- î
def broadcast[T](df: Dataset[T]): Dataset[T]
- î
def bround(e: Column, scale: Int): Column
- î
def bround(e: Column): Column
- î
def bucket(numBuckets: Int, e: Column): Column
- î
def bucket(numBuckets: Column, e: Column): Column
- î
def call_udf(udfName: String, cols: Column*): Column
- î
def cbrt(columnName: String): Column
- î
def cbrt(e: Column): Column
- î
def ceil(columnName: String): Column
- î
def ceil(e: Column): Column
- î
def ceil(e: Column, scale: Column): Column
- î
def clone(): AnyRef
- î
def coalesce(e: Column*): Column
- î
def col(colName: String): Column
- î
def collect_list(columnName: String): Column
- î
def collect_list(e: Column): Column
- î
def collect_set(columnName: String): Column
- î
def collect_set(e: Column): Column
- î
def column(colName: String): Column
- î
def concat(exprs: Column*): Column
- î
def concat_ws(sep: String, exprs: Column*): Column
- î
def conv(num: Column, fromBase: Int, toBase: Int): Column
- î
def corr(columnName1: String, columnName2: String): Column
- î
def corr(column1: Column, column2: Column): Column
- î
def cos(columnName: String): Column
- î
def cos(e: Column): Column
- î
def cosh(columnName: String): Column
- î
def cosh(e: Column): Column
- î
def cot(e: Column): Column
- î
def count(columnName: String): TypedColumn[Any, Long]
- î
def count(e: Column): Column
- î
def countDistinct(columnName: String, columnNames: String*): Column
- î
def countDistinct(expr: Column, exprs: Column*): Column
- î
def count_distinct(expr: Column, exprs: Column*): Column
- î
def covar_pop(columnName1: String, columnName2: String): Column
- î
def covar_pop(column1: Column, column2: Column): Column
- î
def covar_samp(columnName1: String, columnName2: String): Column
- î
def covar_samp(column1: Column, column2: Column): Column
- î
def crc32(e: Column): Column
- î
def csc(e: Column): Column
- î
def cume_dist(): Column
- î
def current_date(): Column
- î
def current_timestamp(): Column
- î
def date_add(start: Column, days: Column): Column
- î
def date_add(start: Column, days: Int): Column
- î
def date_format(dateExpr: Column, format: String): Column
- î
def date_sub(start: Column, days: Column): Column
- î
def date_sub(start: Column, days: Int): Column
- î
def date_trunc(format: String, timestamp: Column): Column
- î
def datediff(end: Column, start: Column): Column
- î
def dayofmonth(e: Column): Column
- î
def dayofweek(e: Column): Column
- î
def dayofyear(e: Column): Column
- î
def days(e: Column): Column
- î
def decode(value: Column, charset: String): Column
- î
def degrees(columnName: String): Column
- î
def degrees(e: Column): Column
- î
def dense_rank(): Column
- î
def desc(columnName: String): Column
- î
def desc_nulls_first(columnName: String): Column
- î
def desc_nulls_last(columnName: String): Column
- î
def element_at(column: Column, value: Any): Column
- î
def encode(value: Column, charset: String): Column
- î
final def eq(arg0: AnyRef): Boolean
- î
def equals(arg0: Any): Boolean
- î
def exists(column: Column, f: (Column) â Column): Column
- î
def exp(columnName: String): Column
- î
def exp(e: Column): Column
- î
def explode(e: Column): Column
- î
def explode_outer(e: Column): Column
- î
def expm1(columnName: String): Column
- î
def expm1(e: Column): Column
- î
def expr(expr: String): Column
- î
def factorial(e: Column): Column
- î
def filter(column: Column, f: (Column, Column) â Column): Column
- î
def filter(column: Column, f: (Column) â Column): Column
- î
def finalize(): Unit
- î
def first(columnName: String): Column
- î
def first(e: Column): Column
- î
def first(columnName: String, ignoreNulls: Boolean): Column
- î
def first(e: Column, ignoreNulls: Boolean): Column
- î
def flatten(e: Column): Column
- î
def floor(columnName: String): Column
- î
def floor(e: Column): Column
- î
def floor(e: Column, scale: Column): Column
- î
def forall(column: Column, f: (Column) â Column): Column
- î
def format_number(x: Column, d: Int): Column
- î
def format_string(format: String, arguments: Column*): Column
- î
def from_csv(e: Column, schema: Column, options: Map[String, String]): Column
- î
def from_csv(e: Column, schema: StructType, options: Map[String, String]): Column
- î
def from_json(e: Column, schema: Column, options: Map[String, String]): Column
- î
def from_json(e: Column, schema: Column): Column
- î
def from_json(e: Column, schema: String, options: Map[String, String]): Column
- î
def from_json(e: Column, schema: String, options: Map[String, String]): Column
- î
def from_json(e: Column, schema: DataType): Column
- î
def from_json(e: Column, schema: StructType): Column
- î
def from_json(e: Column, schema: DataType, options: Map[String, String]): Column
- î
def from_json(e: Column, schema: StructType, options: Map[String, String]): Column
- î
def from_json(e: Column, schema: DataType, options: Map[String, String]): Column
- î
def from_json(e: Column, schema: StructType, options: Map[String, String]): Column
- î
def from_unixtime(ut: Column, f: String): Column
- î
def from_unixtime(ut: Column): Column
- î
def from_utc_timestamp(ts: Column, tz: Column): Column
- î
def from_utc_timestamp(ts: Column, tz: String): Column
- î
final def getClass(): Class[_]
- î
def get_json_object(e: Column, path: String): Column
- î
def greatest(columnName: String, columnNames: String*): Column
- î
def greatest(exprs: Column*): Column
- î
def grouping(columnName: String): Column
- î
def grouping(e: Column): Column
- î
def grouping_id(colName: String, colNames: String*): Column
- î
def grouping_id(cols: Column*): Column
- î
def hash(cols: Column*): Column
- î
def hashCode(): Int
- î
def hex(column: Column): Column
- î
def hour(e: Column): Column
- î
def hours(e: Column): Column
- î
def hypot(l: Double, rightName: String): Column
- î
def hypot(l: Double, r: Column): Column
- î
def hypot(leftName: String, r: Double): Column
- î
def hypot(l: Column, r: Double): Column
- î
def hypot(leftName: String, rightName: String): Column
- î
def hypot(leftName: String, r: Column): Column
- î
def hypot(l: Column, rightName: String): Column
- î
def hypot(l: Column, r: Column): Column
- î
def initcap(e: Column): Column
- î
def input_file_name(): Column
- î
def instr(str: Column, substring: String): Column
- î
final def isInstanceOf[T0]: Boolean
- î
def isnan(e: Column): Column
- î
def isnull(e: Column): Column
- î
def json_tuple(json: Column, fields: String*): Column
- î
def kurtosis(columnName: String): Column
- î
def kurtosis(e: Column): Column
- î
def lag(e: Column, offset: Int, defaultValue: Any, ignoreNulls: Boolean): Column
- î
def lag(e: Column, offset: Int, defaultValue: Any): Column
- î
def lag(columnName: String, offset: Int, defaultValue: Any): Column
- î
def lag(columnName: String, offset: Int): Column
- î
def lag(e: Column, offset: Int): Column
- î
def last(columnName: String): Column
- î
def last(e: Column): Column
- î
def last(columnName: String, ignoreNulls: Boolean): Column
- î
def last(e: Column, ignoreNulls: Boolean): Column
- î
def last_day(e: Column): Column
- î
def lead(e: Column, offset: Int, defaultValue: Any, ignoreNulls: Boolean): Column
- î
def lead(e: Column, offset: Int, defaultValue: Any): Column
- î
def lead(columnName: String, offset: Int, defaultValue: Any): Column
- î
def lead(e: Column, offset: Int): Column
- î
def lead(columnName: String, offset: Int): Column
- î
def least(columnName: String, columnNames: String*): Column
- î
def least(exprs: Column*): Column
- î
def length(e: Column): Column
- î
def levenshtein(l: Column, r: Column): Column
- î
def lit(literal: Any): Column
- î
def localtimestamp(): Column
- î
def locate(substr: String, str: Column, pos: Int): Column
- î
def locate(substr: String, str: Column): Column
- î
def log(base: Double, columnName: String): Column
- î
def log(base: Double, a: Column): Column
- î
def log(columnName: String): Column
- î
def log(e: Column): Column
- î
def log10(columnName: String): Column
- î
def log10(e: Column): Column
- î
def log1p(columnName: String): Column
- î
def log1p(e: Column): Column
- î
def log2(columnName: String): Column
- î
def log2(expr: Column): Column
- î
def lower(e: Column): Column
- î
def lpad(str: Column, len: Int, pad: Array[Byte]): Column
- î
def lpad(str: Column, len: Int, pad: String): Column
- î
def ltrim(e: Column, trimString: String): Column
- î
def ltrim(e: Column): Column
- î
def make_date(year: Column, month: Column, day: Column): Column
- î
def map(cols: Column*): Column
- î
def map_concat(cols: Column*): Column
- î
def map_contains_key(column: Column, key: Any): Column
- î
def map_entries(e: Column): Column
- î
def map_filter(expr: Column, f: (Column, Column) â Column): Column
- î
def map_from_arrays(keys: Column, values: Column): Column
- î
def map_from_entries(e: Column): Column
- î
def map_keys(e: Column): Column
- î
def map_values(e: Column): Column
- î
def map_zip_with(left: Column, right: Column, f: (Column, Column, Column) â Column): Column
- î
def max(columnName: String): Column
- î
def max(e: Column): Column
- î
def max_by(e: Column, ord: Column): Column
- î
def md5(e: Column): Column
- î
def mean(columnName: String): Column
- î
def mean(e: Column): Column
- î
def min(columnName: String): Column
- î
def min(e: Column): Column
- î
def min_by(e: Column, ord: Column): Column
- î
def minute(e: Column): Column
- î
def monotonically_increasing_id(): Column
- î
def month(e: Column): Column
- î
def months(e: Column): Column
- î
def months_between(end: Column, start: Column, roundOff: Boolean): Column
- î
def months_between(end: Column, start: Column): Column
- î
def nanvl(col1: Column, col2: Column): Column
- î
final def ne(arg0: AnyRef): Boolean
- î
def negate(e: Column): Column
- î
def next_day(date: Column, dayOfWeek: Column): Column
- î
def next_day(date: Column, dayOfWeek: String): Column
- î
def not(e: Column): Column
- î
final def notify(): Unit
- î
final def notifyAll(): Unit
- î
def nth_value(e: Column, offset: Int): Column
- î
def nth_value(e: Column, offset: Int, ignoreNulls: Boolean): Column
- î
def ntile(n: Int): Column
- î
def octet_length(e: Column): Column
- î
def overlay(src: Column, replace: Column, pos: Column): Column
- î
def overlay(src: Column, replace: Column, pos: Column, len: Column): Column
- î
def percent_rank(): Column
- î
def percentile_approx(e: Column, percentage: Column, accuracy: Column): Column
- î
def pmod(dividend: Column, divisor: Column): Column
- î
def posexplode(e: Column): Column
- î
def posexplode_outer(e: Column): Column
- î
def pow(l: Double, rightName: String): Column
- î
def pow(l: Double, r: Column): Column
- î
def pow(leftName: String, r: Double): Column
- î
def pow(l: Column, r: Double): Column
- î
def pow(leftName: String, rightName: String): Column
- î
def pow(leftName: String, r: Column): Column
- î
def pow(l: Column, rightName: String): Column
- î
def pow(l: Column, r: Column): Column
- î
def product(e: Column): Column
- î
def quarter(e: Column): Column
- î
def radians(columnName: String): Column
- î
def radians(e: Column): Column
- î
def raise_error(c: Column): Column
- î
def rand(): Column
- î
def rand(seed: Long): Column
- î
def randn(): Column
- î
def randn(seed: Long): Column
- î
def rank(): Column
- î
def regexp_extract(e: Column, exp: String, groupIdx: Int): Column
- î
def regexp_replace(e: Column, pattern: Column, replacement: Column): Column
- î
def regexp_replace(e: Column, pattern: String, replacement: String): Column
- î
def repeat(str: Column, n: Int): Column
- î
def reverse(e: Column): Column
- î
def rint(columnName: String): Column
- î
def rint(e: Column): Column
- î
def round(e: Column, scale: Int): Column
- î
def round(e: Column): Column
- î
def row_number(): Column
- î
def rpad(str: Column, len: Int, pad: Array[Byte]): Column
- î
def rpad(str: Column, len: Int, pad: String): Column
- î
def rtrim(e: Column, trimString: String): Column
- î
def rtrim(e: Column): Column
- î
def schema_of_csv(csv: Column, options: Map[String, String]): Column
- î
def schema_of_csv(csv: Column): Column
- î
def schema_of_csv(csv: String): Column
- î
def schema_of_json(json: Column, options: Map[String, String]): Column
- î
def schema_of_json(json: Column): Column
- î
def schema_of_json(json: String): Column
- î
def sec(e: Column): Column
- î
def second(e: Column): Column
- î
def sentences(string: Column): Column
- î
def sentences(string: Column, language: Column, country: Column): Column
- î
def sequence(start: Column, stop: Column): Column
- î
def sequence(start: Column, stop: Column, step: Column): Column
- î
def session_window(timeColumn: Column, gapDuration: Column): Column
- î
def session_window(timeColumn: Column, gapDuration: String): Column
- î
def sha1(e: Column): Column
- î
def sha2(e: Column, numBits: Int): Column
- î
def shiftleft(e: Column, numBits: Int): Column
- î
def shiftright(e: Column, numBits: Int): Column
- î
def shiftrightunsigned(e: Column, numBits: Int): Column
- î
def shuffle(e: Column): Column
- î
def signum(columnName: String): Column
- î
def signum(e: Column): Column
- î
def sin(columnName: String): Column
- î
def sin(e: Column): Column
- î
def sinh(columnName: String): Column
- î
def sinh(e: Column): Column
- î
def size(e: Column): Column
- î
def skewness(columnName: String): Column
- î
def skewness(e: Column): Column
- î
def slice(x: Column, start: Column, length: Column): Column
- î
def slice(x: Column, start: Int, length: Int): Column
- î
def sort_array(e: Column, asc: Boolean): Column
- î
def sort_array(e: Column): Column
- î
def soundex(e: Column): Column
- î
def spark_partition_id(): Column
- î
def split(str: Column, pattern: String, limit: Int): Column
- î
def split(str: Column, pattern: String): Column
- î
def sqrt(colName: String): Column
- î
def sqrt(e: Column): Column
- î
def stddev(columnName: String): Column
- î
def stddev(e: Column): Column
- î
def stddev_pop(columnName: String): Column
- î
def stddev_pop(e: Column): Column
- î
def stddev_samp(columnName: String): Column
- î
def stddev_samp(e: Column): Column
- î
def struct(colName: String, colNames: String*): Column
- î
def struct(cols: Column*): Column
- î
def substring(str: Column, pos: Int, len: Int): Column
- î
def substring_index(str: Column, delim: String, count: Int): Column
- î
def sum(columnName: String): Column
- î
def sum(e: Column): Column
- î
def sum_distinct(e: Column): Column
- î
final def synchronized[T0](arg0: â T0): T0
- î
def tan(columnName: String): Column
- î
def tan(e: Column): Column
- î
def tanh(columnName: String): Column
- î
def tanh(e: Column): Column
- î
def timestamp_seconds(e: Column): Column
- î
def toString(): String
- î
def to_csv(e: Column): Column
- î
def to_csv(e: Column, options: Map[String, String]): Column
- î
def to_date(e: Column, fmt: String): Column
- î
def to_date(e: Column): Column
- î
def to_json(e: Column): Column
- î
def to_json(e: Column, options: Map[String, String]): Column
- î
def to_json(e: Column, options: Map[String, String]): Column
- î
def to_timestamp(s: Column, fmt: String): Column
- î
def to_timestamp(s: Column): Column
- î
def to_utc_timestamp(ts: Column, tz: Column): Column
- î
def to_utc_timestamp(ts: Column, tz: String): Column
- î
def transform(column: Column, f: (Column, Column) â Column): Column
- î
def transform(column: Column, f: (Column) â Column): Column
- î
def transform_keys(expr: Column, f: (Column, Column) â Column): Column
- î
def transform_values(expr: Column, f: (Column, Column) â Column): Column
- î
def translate(src: Column, matchingString: String, replaceString: String): Column
- î
def trim(e: Column, trimString: String): Column
- î
def trim(e: Column): Column
- î
def trunc(date: Column, format: String): Column
- î
def typedLit[T](literal: T)(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[T]): Column
- î
def typedlit[T](literal: T)(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[T]): Column
- î
def udaf[IN, BUF, OUT](agg: expressions.Aggregator[IN, BUF, OUT], inputEncoder: Encoder[IN]): UserDefinedFunction
- î
def udaf[IN, BUF, OUT](agg: expressions.Aggregator[IN, BUF, OUT])(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[IN]): UserDefinedFunction
- î
def udf(f: UDF10[_, _, _, _, _, _, _, _, _, _, _], returnType: DataType): UserDefinedFunction
- î
def udf(f: UDF9[_, _, _, _, _, _, _, _, _, _], returnType: DataType): UserDefinedFunction
- î
def udf(f: UDF8[_, _, _, _, _, _, _, _, _], returnType: DataType): UserDefinedFunction
- î
def udf(f: UDF7[_, _, _, _, _, _, _, _], returnType: DataType): UserDefinedFunction
- î
def udf(f: UDF6[_, _, _, _, _, _, _], returnType: DataType): UserDefinedFunction
- î
def udf(f: UDF5[_, _, _, _, _, _], returnType: DataType): UserDefinedFunction
- î
def udf(f: UDF4[_, _, _, _, _], returnType: DataType): UserDefinedFunction
- î
def udf(f: UDF3[_, _, _, _], returnType: DataType): UserDefinedFunction
- î
def udf(f: UDF2[_, _, _], returnType: DataType): UserDefinedFunction
- î
def udf(f: UDF1[_, _], returnType: DataType): UserDefinedFunction
- î
def udf(f: UDF0[_], returnType: DataType): UserDefinedFunction
- î
def udf[RT, A1, A2, A3, A4, A5, A6, A7, A8, A9, A10](f: (A1, A2, A3, A4, A5, A6, A7, A8, A9, A10) â RT)(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[RT], arg1: scala.reflect.api.JavaUniverse.TypeTag[A1], arg2: scala.reflect.api.JavaUniverse.TypeTag[A2], arg3: scala.reflect.api.JavaUniverse.TypeTag[A3], arg4: scala.reflect.api.JavaUniverse.TypeTag[A4], arg5: scala.reflect.api.JavaUniverse.TypeTag[A5], arg6: scala.reflect.api.JavaUniverse.TypeTag[A6], arg7: scala.reflect.api.JavaUniverse.TypeTag[A7], arg8: scala.reflect.api.JavaUniverse.TypeTag[A8], arg9: scala.reflect.api.JavaUniverse.TypeTag[A9], arg10: scala.reflect.api.JavaUniverse.TypeTag[A10]): UserDefinedFunction
- î
def udf[RT, A1, A2, A3, A4, A5, A6, A7, A8, A9](f: (A1, A2, A3, A4, A5, A6, A7, A8, A9) â RT)(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[RT], arg1: scala.reflect.api.JavaUniverse.TypeTag[A1], arg2: scala.reflect.api.JavaUniverse.TypeTag[A2], arg3: scala.reflect.api.JavaUniverse.TypeTag[A3], arg4: scala.reflect.api.JavaUniverse.TypeTag[A4], arg5: scala.reflect.api.JavaUniverse.TypeTag[A5], arg6: scala.reflect.api.JavaUniverse.TypeTag[A6], arg7: scala.reflect.api.JavaUniverse.TypeTag[A7], arg8: scala.reflect.api.JavaUniverse.TypeTag[A8], arg9: scala.reflect.api.JavaUniverse.TypeTag[A9]): UserDefinedFunction
- î
def udf[RT, A1, A2, A3, A4, A5, A6, A7, A8](f: (A1, A2, A3, A4, A5, A6, A7, A8) â RT)(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[RT], arg1: scala.reflect.api.JavaUniverse.TypeTag[A1], arg2: scala.reflect.api.JavaUniverse.TypeTag[A2], arg3: scala.reflect.api.JavaUniverse.TypeTag[A3], arg4: scala.reflect.api.JavaUniverse.TypeTag[A4], arg5: scala.reflect.api.JavaUniverse.TypeTag[A5], arg6: scala.reflect.api.JavaUniverse.TypeTag[A6], arg7: scala.reflect.api.JavaUniverse.TypeTag[A7], arg8: scala.reflect.api.JavaUniverse.TypeTag[A8]): UserDefinedFunction
- î
def udf[RT, A1, A2, A3, A4, A5, A6, A7](f: (A1, A2, A3, A4, A5, A6, A7) â RT)(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[RT], arg1: scala.reflect.api.JavaUniverse.TypeTag[A1], arg2: scala.reflect.api.JavaUniverse.TypeTag[A2], arg3: scala.reflect.api.JavaUniverse.TypeTag[A3], arg4: scala.reflect.api.JavaUniverse.TypeTag[A4], arg5: scala.reflect.api.JavaUniverse.TypeTag[A5], arg6: scala.reflect.api.JavaUniverse.TypeTag[A6], arg7: scala.reflect.api.JavaUniverse.TypeTag[A7]): UserDefinedFunction
- î
def udf[RT, A1, A2, A3, A4, A5, A6](f: (A1, A2, A3, A4, A5, A6) â RT)(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[RT], arg1: scala.reflect.api.JavaUniverse.TypeTag[A1], arg2: scala.reflect.api.JavaUniverse.TypeTag[A2], arg3: scala.reflect.api.JavaUniverse.TypeTag[A3], arg4: scala.reflect.api.JavaUniverse.TypeTag[A4], arg5: scala.reflect.api.JavaUniverse.TypeTag[A5], arg6: scala.reflect.api.JavaUniverse.TypeTag[A6]): UserDefinedFunction
- î
def udf[RT, A1, A2, A3, A4, A5](f: (A1, A2, A3, A4, A5) â RT)(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[RT], arg1: scala.reflect.api.JavaUniverse.TypeTag[A1], arg2: scala.reflect.api.JavaUniverse.TypeTag[A2], arg3: scala.reflect.api.JavaUniverse.TypeTag[A3], arg4: scala.reflect.api.JavaUniverse.TypeTag[A4], arg5: scala.reflect.api.JavaUniverse.TypeTag[A5]): UserDefinedFunction
- î
def udf[RT, A1, A2, A3, A4](f: (A1, A2, A3, A4) â RT)(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[RT], arg1: scala.reflect.api.JavaUniverse.TypeTag[A1], arg2: scala.reflect.api.JavaUniverse.TypeTag[A2], arg3: scala.reflect.api.JavaUniverse.TypeTag[A3], arg4: scala.reflect.api.JavaUniverse.TypeTag[A4]): UserDefinedFunction
- î
def udf[RT, A1, A2, A3](f: (A1, A2, A3) â RT)(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[RT], arg1: scala.reflect.api.JavaUniverse.TypeTag[A1], arg2: scala.reflect.api.JavaUniverse.TypeTag[A2], arg3: scala.reflect.api.JavaUniverse.TypeTag[A3]): UserDefinedFunction
- î
def udf[RT, A1, A2](f: (A1, A2) â RT)(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[RT], arg1: scala.reflect.api.JavaUniverse.TypeTag[A1], arg2: scala.reflect.api.JavaUniverse.TypeTag[A2]): UserDefinedFunction
- î
def udf[RT, A1](f: (A1) â RT)(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[RT], arg1: scala.reflect.api.JavaUniverse.TypeTag[A1]): UserDefinedFunction
- î
def udf[RT](f: () â RT)(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[RT]): UserDefinedFunction
- î
def unbase64(e: Column): Column
- î
def unhex(column: Column): Column
- î
def unix_timestamp(s: Column, p: String): Column
- î
def unix_timestamp(s: Column): Column
- î
def unix_timestamp(): Column
- î
def unwrap_udt(column: Column): Column
- î
def upper(e: Column): Column
- î
def var_pop(columnName: String): Column
- î
def var_pop(e: Column): Column
- î
def var_samp(columnName: String): Column
- î
def var_samp(e: Column): Column
- î
def variance(columnName: String): Column
- î
def variance(e: Column): Column
- î
final def wait(): Unit
- î
final def wait(arg0: Long, arg1: Int): Unit
- î
final def wait(arg0: Long): Unit
- î
def weekofyear(e: Column): Column
- î
def when(condition: Column, value: Any): Column
- î
def window(timeColumn: Column, windowDuration: String): Column
- î
def window(timeColumn: Column, windowDuration: String, slideDuration: String): Column
- î
def window(timeColumn: Column, windowDuration: String, slideDuration: String, startTime: String): Column
- î
def xxhash64(cols: Column*): Column
- î
def year(e: Column): Column
- î
def years(e: Column): Column
- î
def zip_with(left: Column, right: Column, f: (Column, Column) â Column): Column
Aggregate functions
Collection functions
Date time functions
Math functions
Misc functions
Non-aggregate functions
Partition transform functions
Sorting functions
String functions
UDF functions
Window functions
Support functions for DataFrames
RetroSearch is an open source project built by @garambo
| Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4