Showing content from http://spark.apache.org/docs/latest/api/scala/org/apache/spark/sql/functions$.html below:
Spark 4.0.0 ScalaDoc - org.apache.spark.sql.functions
object functions
î·î
Ordering
- Grouped
- Alphabetic
- By Inheritance
Inherited
- functions
- AnyRef
- Any
Visibility
- Public
- Protected
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 aes_decrypt(input: Column, key: Column): Column
- î
def aes_decrypt(input: Column, key: Column, mode: Column): Column
- î
def aes_decrypt(input: Column, key: Column, mode: Column, padding: Column): Column
- î
def aes_decrypt(input: Column, key: Column, mode: Column, padding: Column, aad: Column): Column
- î
def aes_encrypt(input: Column, key: Column): Column
- î
def aes_encrypt(input: Column, key: Column, mode: Column): Column
- î
def aes_encrypt(input: Column, key: Column, mode: Column, padding: Column): Column
- î
def aes_encrypt(input: Column, key: Column, mode: Column, padding: Column, iv: Column): Column
- î
def aes_encrypt(input: Column, key: Column, mode: Column, padding: Column, iv: Column, aad: Column): 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 any(e: Column): Column
- î
def any_value(e: Column, ignoreNulls: Column): Column
- î
def any_value(e: 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 approx_percentile(e: Column, percentage: Column, accuracy: Column): Column
- î
def array(colName: String, colNames: String*): Column
- î
def array(cols: Column*): Column
- î
def array_agg(e: Column): Column
- î
def array_append(column: Column, element: Any): Column
- î
def array_compact(column: 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_insert(arr: Column, pos: Column, value: 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_prepend(column: Column, element: 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_size(e: Column): Column
- î
def array_sort(e: Column, comparator: (Column, Column) => 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_and(e: Column): Column
- î
def bit_count(e: Column): Column
- î
def bit_get(e: Column, pos: Column): Column
- î
def bit_length(e: Column): Column
- î
def bit_or(e: Column): Column
- î
def bit_xor(e: Column): Column
- î
def bitmap_bit_position(col: Column): Column
- î
def bitmap_bucket_number(col: Column): Column
- î
def bitmap_construct_agg(col: Column): Column
- î
def bitmap_count(col: Column): Column
- î
def bitmap_or_agg(col: Column): Column
- î
def bitwise_not(e: Column): Column
- î
def bool_and(e: Column): Column
- î
def bool_or(e: Column): Column
- î
def broadcast[U](df: Dataset[U]): df.type
- î
def bround(e: Column, scale: Column): Column
- î
def bround(e: Column, scale: Int): Column
- î
def bround(e: Column): Column
- î
def btrim(str: Column, trim: Column): Column
- î
def btrim(str: Column): Column
- î
def bucket(numBuckets: Int, e: Column): Column
- î
def bucket(numBuckets: Column, e: Column): Column
- î
def call_function(funcName: String, cols: Column*): Column
- î
def call_udf(udfName: String, cols: Column*): Column
- î
def cardinality(e: 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 ceiling(e: Column): Column
- î
def ceiling(e: Column, scale: Column): Column
- î
def char(n: Column): Column
- î
def char_length(str: Column): Column
- î
def character_length(str: Column): Column
- î
def chr(n: Column): Column
- î
def clone(): AnyRef
- î
def coalesce(e: Column*): Column
- î
def col(colName: String): Column
- î
def collate(e: Column, collation: String): Column
- î
def collation(e: Column): 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 contains(left: Column, right: Column): Column
- î
def conv(num: Column, fromBase: Int, toBase: Int): Column
- î
def convert_timezone(targetTz: Column, sourceTs: Column): Column
- î
def convert_timezone(sourceTz: Column, targetTz: Column, sourceTs: Column): 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 count_if(e: Column): Column
- î
def count_min_sketch(e: Column, eps: Column, confidence: Column): Column
- î
def count_min_sketch(e: Column, eps: Column, confidence: Column, seed: 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 curdate(): Column
- î
def current_catalog(): Column
- î
def current_database(): Column
- î
def current_date(): Column
- î
def current_schema(): Column
- î
def current_timestamp(): Column
- î
def current_timezone(): Column
- î
def current_user(): Column
- î
def date_add(start: Column, days: Column): Column
- î
def date_add(start: Column, days: Int): Column
- î
def date_diff(end: Column, start: Column): Column
- î
def date_format(dateExpr: Column, format: String): Column
- î
def date_from_unix_date(days: Column): Column
- î
def date_part(field: Column, source: Column): 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 dateadd(start: Column, days: Column): Column
- î
def datediff(end: Column, start: Column): Column
- î
def datepart(field: Column, source: Column): Column
- î
def day(e: Column): Column
- î
def dayname(timeExp: 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 e(): Column
- î
def element_at(column: Column, value: Any): Column
- î
def elt(inputs: Column*): Column
- î
def encode(value: Column, charset: String): Column
- î
def endswith(str: Column, suffix: Column): Column
- î
final def eq(arg0: AnyRef): Boolean
- î
def equal_null(col1: Column, col2: Column): Column
- î
def equals(arg0: AnyRef): Boolean
- î
def every(e: Column): Column
- î
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 extract(field: Column, source: Column): Column
- î
def factorial(e: Column): Column
- î
def filter(column: Column, f: (Column, Column) => Column): Column
- î
def filter(column: Column, f: (Column) => Column): Column
- î
def find_in_set(str: Column, strArray: Column): Column
- î
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 first_value(e: Column, ignoreNulls: Column): Column
- î
def first_value(e: Column): 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
- î
def from_xml(e: Column, schema: StructType): Column
- î
def from_xml(e: Column, schema: Column, options: Map[String, String]): Column
- î
def from_xml(e: Column, schema: Column): Column
- î
def from_xml(e: Column, schema: String, options: Map[String, String]): Column
- î
def from_xml(e: Column, schema: StructType, options: Map[String, String]): Column
- î
def get(column: Column, index: Column): Column
- î
final def getClass(): Class[_ <: AnyRef]
- î
def get_json_object(e: Column, path: String): Column
- î
def getbit(e: Column, pos: Column): 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 histogram_numeric(e: Column, nBins: Column): Column
- î
def hll_sketch_agg(columnName: String): Column
- î
def hll_sketch_agg(e: Column): Column
- î
def hll_sketch_agg(columnName: String, lgConfigK: Int): Column
- î
def hll_sketch_agg(e: Column, lgConfigK: Int): Column
- î
def hll_sketch_agg(e: Column, lgConfigK: Column): Column
- î
def hll_sketch_estimate(columnName: String): Column
- î
def hll_sketch_estimate(c: Column): Column
- î
def hll_union(columnName1: String, columnName2: String, allowDifferentLgConfigK: Boolean): Column
- î
def hll_union(c1: Column, c2: Column, allowDifferentLgConfigK: Boolean): Column
- î
def hll_union(columnName1: String, columnName2: String): Column
- î
def hll_union(c1: Column, c2: Column): Column
- î
def hll_union_agg(columnName: String): Column
- î
def hll_union_agg(e: Column): Column
- î
def hll_union_agg(columnName: String, allowDifferentLgConfigK: Boolean): Column
- î
def hll_union_agg(e: Column, allowDifferentLgConfigK: Boolean): Column
- î
def hll_union_agg(e: Column, allowDifferentLgConfigK: 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 ifnull(col1: Column, col2: Column): Column
- î
def ilike(str: Column, pattern: Column): Column
- î
def ilike(str: Column, pattern: Column, escapeChar: Column): Column
- î
def initcap(e: Column): Column
- î
def inline(e: Column): Column
- î
def inline_outer(e: Column): Column
- î
def input_file_block_length(): Column
- î
def input_file_block_start(): Column
- î
def input_file_name(): Column
- î
def instr(str: Column, substring: Column): Column
- î
def instr(str: Column, substring: String): Column
- î
final def isInstanceOf[T0]: Boolean
- î
def is_valid_utf8(str: Column): Column
- î
def is_variant_null(v: Column): Column
- î
def isnan(e: Column): Column
- î
def isnotnull(col: Column): Column
- î
def isnull(e: Column): Column
- î
def java_method(cols: Column*): Column
- î
def json_array_length(e: Column): Column
- î
def json_object_keys(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 last_value(e: Column, ignoreNulls: Column): Column
- î
def last_value(e: Column): Column
- î
def lcase(str: 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 left(str: Column, len: Column): Column
- î
def len(e: Column): Column
- î
def length(e: Column): Column
- î
def levenshtein(l: Column, r: Column): Column
- î
def levenshtein(l: Column, r: Column, threshold: Int): Column
- î
def like(str: Column, pattern: Column): Column
- î
def like(str: Column, pattern: Column, escapeChar: Column): Column
- î
def listagg(e: Column, delimiter: Column): Column
- î
def listagg(e: Column): Column
- î
def listagg_distinct(e: Column, delimiter: Column): Column
- î
def listagg_distinct(e: Column): Column
- î
def lit(literal: Any): Column
- î
def ln(e: Column): 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: Column, pad: 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, trim: Column): Column
- î
def ltrim(e: Column, trimString: String): Column
- î
def ltrim(e: Column): Column
- î
def make_date(year: Column, month: Column, day: Column): Column
- î
def make_dt_interval(): Column
- î
def make_dt_interval(days: Column): Column
- î
def make_dt_interval(days: Column, hours: Column): Column
- î
def make_dt_interval(days: Column, hours: Column, mins: Column): Column
- î
def make_dt_interval(days: Column, hours: Column, mins: Column, secs: Column): Column
- î
def make_interval(): Column
- î
def make_interval(years: Column): Column
- î
def make_interval(years: Column, months: Column): Column
- î
def make_interval(years: Column, months: Column, weeks: Column): Column
- î
def make_interval(years: Column, months: Column, weeks: Column, days: Column): Column
- î
def make_interval(years: Column, months: Column, weeks: Column, days: Column, hours: Column): Column
- î
def make_interval(years: Column, months: Column, weeks: Column, days: Column, hours: Column, mins: Column): Column
- î
def make_interval(years: Column, months: Column, weeks: Column, days: Column, hours: Column, mins: Column, secs: Column): Column
- î
def make_timestamp(years: Column, months: Column, days: Column, hours: Column, mins: Column, secs: Column): Column
- î
def make_timestamp(years: Column, months: Column, days: Column, hours: Column, mins: Column, secs: Column, timezone: Column): Column
- î
def make_timestamp_ltz(years: Column, months: Column, days: Column, hours: Column, mins: Column, secs: Column): Column
- î
def make_timestamp_ltz(years: Column, months: Column, days: Column, hours: Column, mins: Column, secs: Column, timezone: Column): Column
- î
def make_timestamp_ntz(years: Column, months: Column, days: Column, hours: Column, mins: Column, secs: Column): Column
- î
def make_valid_utf8(str: Column): Column
- î
def make_ym_interval(): Column
- î
def make_ym_interval(years: Column): Column
- î
def make_ym_interval(years: Column, months: 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 mask(input: Column, upperChar: Column, lowerChar: Column, digitChar: Column, otherChar: Column): Column
- î
def mask(input: Column, upperChar: Column, lowerChar: Column, digitChar: Column): Column
- î
def mask(input: Column, upperChar: Column, lowerChar: Column): Column
- î
def mask(input: Column, upperChar: Column): Column
- î
def mask(input: 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 median(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 mode(e: Column, deterministic: Boolean): Column
- î
def mode(e: Column): Column
- î
def monotonically_increasing_id(): Column
- î
def month(e: Column): Column
- î
def monthname(timeExp: 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 named_struct(cols: Column*): Column
- î
def nanvl(col1: Column, col2: Column): Column
- î
final def ne(arg0: AnyRef): Boolean
- î
def negate(e: Column): Column
- î
def negative(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 now(): Column
- î
def nth_value(e: Column, offset: Int): Column
- î
def nth_value(e: Column, offset: Int, ignoreNulls: Boolean): Column
- î
def ntile(n: Int): Column
- î
def nullif(col1: Column, col2: Column): Column
- î
def nullifzero(col: Column): Column
- î
def nvl(col1: Column, col2: Column): Column
- î
def nvl2(col1: Column, col2: Column, col3: Column): 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 parse_json(json: Column): Column
- î
def parse_url(url: Column, partToExtract: Column): Column
- î
def parse_url(url: Column, partToExtract: Column, key: Column): Column
- î
def percent_rank(): Column
- î
def percentile(e: Column, percentage: Column, frequency: Column): Column
- î
def percentile(e: Column, percentage: Column): Column
- î
def percentile_approx(e: Column, percentage: Column, accuracy: Column): Column
- î
def pi(): Column
- î
def pmod(dividend: Column, divisor: Column): Column
- î
def posexplode(e: Column): Column
- î
def posexplode_outer(e: Column): Column
- î
def position(substr: Column, str: Column): Column
- î
def position(substr: Column, str: Column, start: Column): Column
- î
def positive(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 power(l: Column, r: Column): Column
- î
def printf(format: Column, arguments: 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 random(): Column
- î
def random(seed: Column): Column
- î
def randstr(length: Column, seed: Column): Column
- î
def randstr(length: Column): Column
- î
def rank(): Column
- î
def reduce(expr: Column, initialValue: Column, merge: (Column, Column) => Column): Column
- î
def reduce(expr: Column, initialValue: Column, merge: (Column, Column) => Column, finish: (Column) => Column): Column
- î
def reflect(cols: Column*): Column
- î
def regexp(str: Column, regexp: Column): Column
- î
def regexp_count(str: Column, regexp: Column): Column
- î
def regexp_extract(e: Column, exp: String, groupIdx: Int): Column
- î
def regexp_extract_all(str: Column, regexp: Column, idx: Column): Column
- î
def regexp_extract_all(str: Column, regexp: Column): Column
- î
def regexp_instr(str: Column, regexp: Column, idx: Column): Column
- î
def regexp_instr(str: Column, regexp: Column): Column
- î
def regexp_like(str: Column, regexp: Column): Column
- î
def regexp_replace(e: Column, pattern: Column, replacement: Column): Column
- î
def regexp_replace(e: Column, pattern: String, replacement: String): Column
- î
def regexp_substr(str: Column, regexp: Column): Column
- î
def regr_avgx(y: Column, x: Column): Column
- î
def regr_avgy(y: Column, x: Column): Column
- î
def regr_count(y: Column, x: Column): Column
- î
def regr_intercept(y: Column, x: Column): Column
- î
def regr_r2(y: Column, x: Column): Column
- î
def regr_slope(y: Column, x: Column): Column
- î
def regr_sxx(y: Column, x: Column): Column
- î
def regr_sxy(y: Column, x: Column): Column
- î
def regr_syy(y: Column, x: Column): Column
- î
def repeat(str: Column, n: Column): Column
- î
def repeat(str: Column, n: Int): Column
- î
def replace(src: Column, search: Column): Column
- î
def replace(src: Column, search: Column, replace: Column): Column
- î
def reverse(e: Column): Column
- î
def right(str: Column, len: Column): Column
- î
def rint(columnName: String): Column
- î
def rint(e: Column): Column
- î
def rlike(str: Column, regexp: Column): Column
- î
def round(e: Column, scale: Column): Column
- î
def round(e: Column, scale: Int): Column
- î
def round(e: Column): Column
- î
def row_number(): Column
- î
def rpad(str: Column, len: Column, pad: Column): Column
- î
def rpad(str: Column, len: Int, pad: Array[Byte]): Column
- î
def rpad(str: Column, len: Int, pad: String): Column
- î
def rtrim(e: Column, trim: Column): 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 schema_of_variant(v: Column): Column
- î
def schema_of_variant_agg(v: Column): Column
- î
def schema_of_xml(xml: Column, options: Map[String, String]): Column
- î
def schema_of_xml(xml: Column): Column
- î
def schema_of_xml(xml: String): Column
- î
def sec(e: Column): Column
- î
def second(e: Column): Column
- î
def sentences(string: Column): Column
- î
def sentences(string: Column, language: 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_user(): Column
- î
def session_window(timeColumn: Column, gapDuration: Column): Column
- î
def session_window(timeColumn: Column, gapDuration: String): Column
- î
def sha(col: Column): 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, seed: Column): Column
- î
def shuffle(e: Column): Column
- î
def sign(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 some(e: Column): 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: Column, limit: Column): Column
- î
def split(str: Column, pattern: String, limit: Int): Column
- î
def split(str: Column, pattern: Column): Column
- î
def split(str: Column, pattern: String): Column
- î
def split_part(str: Column, delimiter: Column, partNum: Column): Column
- î
def sqrt(colName: String): Column
- î
def sqrt(e: Column): Column
- î
def stack(cols: Column*): Column
- î
def startswith(str: Column, prefix: Column): Column
- î
def std(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 str_to_map(text: Column): Column
- î
def str_to_map(text: Column, pairDelim: Column): Column
- î
def str_to_map(text: Column, pairDelim: Column, keyValueDelim: Column): Column
- î
def string_agg(e: Column, delimiter: Column): Column
- î
def string_agg(e: Column): Column
- î
def string_agg_distinct(e: Column, delimiter: Column): Column
- î
def string_agg_distinct(e: Column): Column
- î
def struct(colName: String, colNames: String*): Column
- î
def struct(cols: Column*): Column
- î
def substr(str: Column, pos: Column): Column
- î
def substr(str: Column, pos: Column, len: Column): Column
- î
def substring(str: Column, pos: Column, len: 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_add(unit: String, quantity: Column, ts: Column): Column
- î
def timestamp_diff(unit: String, start: Column, end: Column): Column
- î
def timestamp_micros(e: Column): Column
- î
def timestamp_millis(e: Column): Column
- î
def timestamp_seconds(e: Column): Column
- î
def toString(): String
- î
def to_binary(e: Column): Column
- î
def to_binary(e: Column, f: Column): Column
- î
def to_char(e: Column, format: Column): Column
- î
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_number(e: Column, format: Column): Column
- î
def to_timestamp(s: Column, fmt: String): Column
- î
def to_timestamp(s: Column): Column
- î
def to_timestamp_ltz(timestamp: Column): Column
- î
def to_timestamp_ltz(timestamp: Column, format: Column): Column
- î
def to_timestamp_ntz(timestamp: Column): Column
- î
def to_timestamp_ntz(timestamp: Column, format: Column): Column
- î
def to_unix_timestamp(timeExp: Column): Column
- î
def to_unix_timestamp(timeExp: Column, format: Column): Column
- î
def to_utc_timestamp(ts: Column, tz: Column): Column
- î
def to_utc_timestamp(ts: Column, tz: String): Column
- î
def to_varchar(e: Column, format: Column): Column
- î
def to_variant_object(col: Column): Column
- î
def to_xml(e: Column): Column
- î
def to_xml(e: Column, options: Map[String, 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, trim: Column): Column
- î
def trim(e: Column, trimString: String): Column
- î
def trim(e: Column): Column
- î
def trunc(date: Column, format: String): Column
- î
def try_add(left: Column, right: Column): Column
- î
def try_aes_decrypt(input: Column, key: Column): Column
- î
def try_aes_decrypt(input: Column, key: Column, mode: Column): Column
- î
def try_aes_decrypt(input: Column, key: Column, mode: Column, padding: Column): Column
- î
def try_aes_decrypt(input: Column, key: Column, mode: Column, padding: Column, aad: Column): Column
- î
def try_avg(e: Column): Column
- î
def try_divide(left: Column, right: Column): Column
- î
def try_element_at(column: Column, value: Column): Column
- î
def try_make_interval(years: Column): Column
- î
def try_make_interval(years: Column, months: Column): Column
- î
def try_make_interval(years: Column, months: Column, weeks: Column): Column
- î
def try_make_interval(years: Column, months: Column, weeks: Column, days: Column): Column
- î
def try_make_interval(years: Column, months: Column, weeks: Column, days: Column, hours: Column): Column
- î
def try_make_interval(years: Column, months: Column, weeks: Column, days: Column, hours: Column, mins: Column): Column
- î
def try_make_interval(years: Column, months: Column, weeks: Column, days: Column, hours: Column, mins: Column, secs: Column): Column
- î
def try_make_timestamp(years: Column, months: Column, days: Column, hours: Column, mins: Column, secs: Column): Column
- î
def try_make_timestamp(years: Column, months: Column, days: Column, hours: Column, mins: Column, secs: Column, timezone: Column): Column
- î
def try_make_timestamp_ltz(years: Column, months: Column, days: Column, hours: Column, mins: Column, secs: Column): Column
- î
def try_make_timestamp_ltz(years: Column, months: Column, days: Column, hours: Column, mins: Column, secs: Column, timezone: Column): Column
- î
def try_make_timestamp_ntz(years: Column, months: Column, days: Column, hours: Column, mins: Column, secs: Column): Column
- î
def try_mod(left: Column, right: Column): Column
- î
def try_multiply(left: Column, right: Column): Column
- î
def try_parse_json(json: Column): Column
- î
def try_parse_url(url: Column, partToExtract: Column): Column
- î
def try_parse_url(url: Column, partToExtract: Column, key: Column): Column
- î
def try_reflect(cols: Column*): Column
- î
def try_subtract(left: Column, right: Column): Column
- î
def try_sum(e: Column): Column
- î
def try_to_binary(e: Column): Column
- î
def try_to_binary(e: Column, f: Column): Column
- î
def try_to_number(e: Column, format: Column): Column
- î
def try_to_timestamp(s: Column): Column
- î
def try_to_timestamp(s: Column, format: Column): Column
- î
def try_url_decode(str: Column): Column
- î
def try_validate_utf8(str: Column): Column
- î
def try_variant_get(v: Column, path: Column, targetType: String): Column
- î
def try_variant_get(v: Column, path: String, targetType: 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 typeof(col: Column): Column
- î
def ucase(str: Column): 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 uniform(min: Column, max: Column, seed: Column): Column
- î
def uniform(min: Column, max: Column): Column
- î
def unix_date(e: Column): Column
- î
def unix_micros(e: Column): Column
- î
def unix_millis(e: Column): Column
- î
def unix_seconds(e: 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 url_decode(str: Column): Column
- î
def url_encode(str: Column): Column
- î
def user(): Column
- î
def uuid(): Column
- î
def validate_utf8(str: 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
- î
def variant_get(v: Column, path: Column, targetType: String): Column
- î
def variant_get(v: Column, path: String, targetType: String): Column
- î
def version(): Column
- î
final def wait(arg0: Long, arg1: Int): Unit
- î
final def wait(arg0: Long): Unit
- î
final def wait(): Unit
- î
def weekday(e: Column): Column
- î
def weekofyear(e: Column): Column
- î
def when(condition: Column, value: Any): Column
- î
def width_bucket(v: Column, min: Column, max: Column, numBucket: Column): 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 window_time(windowColumn: Column): Column
- î
def xpath(xml: Column, path: Column): Column
- î
def xpath_boolean(xml: Column, path: Column): Column
- î
def xpath_double(xml: Column, path: Column): Column
- î
def xpath_float(xml: Column, path: Column): Column
- î
def xpath_int(xml: Column, path: Column): Column
- î
def xpath_long(xml: Column, path: Column): Column
- î
def xpath_number(xml: Column, path: Column): Column
- î
def xpath_short(xml: Column, path: Column): Column
- î
def xpath_string(xml: Column, path: Column): Column
- î
def xxhash64(cols: Column*): Column
- î
def year(e: Column): Column
- î
def years(e: Column): Column
- î
def zeroifnull(col: Column): Column
- î
def zip_with(left: Column, right: Column, f: (Column, Column) => Column): Column
- î
object partitioning
Inherited from AnyRef
Inherited from Any
Aggregate functions
Array functions
Bitwise functions
Collection functions
Conditional functions
CSV functions
Date and Timestamp functions
Generator functions
Hash functions
JSON functions
Map functions
Mathematical functions
Misc functions
Normal functions
Partition transform functions
Predicate functions
Sort functions
String functions
Struct functions
UDF, UDAF and UDT
URL functions
VARIANT functions
Window functions
XML 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