Skip to content

Miscellaneous Functions

Function Description
aes_decrypt(input, key, mode, padding) Расшифровывает данные с помощью AES.
aes_encrypt(input, key, mode, padding) Шифрует данные с помощью AES.
assert_true(condition, message) Проверяет условие и вызывает исключение, если оно ложно.
bitmap_bit_position(col) Возвращает позицию бита в битовой карте.
bitmap_bucket_number(col) Возвращает номер корзины в битовой карте.
bitmap_construct_agg(col) Создает битовую карту из значений.
bitmap_count(col) Подсчитывает количество установленных битов в битовой карте.
bitmap_or_agg(col) Выполняет побитовое ИЛИ над битовыми картами.
crc32(col) Вычисляет CRC32 значение.
current_catalog() Возвращает текущий каталог.
current_database() Возвращает текущую базу данных.
current_schema() Возвращает текущую схему.
current_user() Возвращает текущего пользователя.
database() Возвращает имя текущей базы данных.
input_file_block_length() Возвращает длину блока входного файла.
input_file_block_start() Возвращает начальную позицию блока входного файла.
input_file_name() Возвращает имя входного файла.
java_method(class, method, *args) Вызывает метод Java.
monotonically_increasing_id() Генерирует монотонно возрастающий идентификатор.
reflect(class, method, *args) Вызывает метод через отражение.
schema_of_csv(csv) Возвращает схему CSV-строки.
schema_of_json(json) Возвращает схему JSON-строки.
session_user() Возвращает имя пользователя сессии.
spark_partition_id() Возвращает идентификатор партиции Spark.
typeof(col) Возвращает тип данных столбца.
user() Возвращает имя текущего пользователя.
version() Возвращает версию Spark.