-
Utility
_.attempt(func) Arguments Returns Example .callback([func=.identity], [thisArg]) Aliases Arguments Returns Example _.constant(value) Arguments Returns Example _.identi... -
Flink DataStream
Reading with DataStream Batch mode Streaming mode Streaming mode (LogStore) Streaming mode (FileStore) Writing with DataStream Overwrite data Appending data Reading with ... -
Spark Getting Started
Paimon Format Mixed Format Adding catalogs Creating a table Writing to the table Reading from the table The Iceberg Format can be accessed using the Connector provided by Ic... -
Collect Information
Before deploying a cluster, you should collect the following information: The fully qualified domain name (FQDN) of each host in your system. The Ambari Cluster Install wizard s... -
SQL Lineage Support
Introduction Example Lineage specific identification SQL type support Query Command Building Build with Apache Maven Build against Different Apache Spark Versions Test with... -
Encryption
Encrypt Copy-on-Write tables Note Since Hudi 0.11.0, Spark 3.2 support has been added and accompanying that, Parquet 1.12 has been included, which brings encryption feature to H... -
Flink DDL
Create catalogs Flink SQL YAML configuration CREATE statement CREATE DATABASE CREATE TABLE PARTITIONED BY CREATE TABLE LIKE DROP statement DROP DATABASE DROP TABLE SHOW ... -
Chain
_(value) Arguments Returns Example _.chain(value) Arguments Returns Example _.tap(value, interceptor, [thisArg]) Arguments Returns Example _.thru(value, interceptor, [t... -
Flink Configuration
Catalog Configuration Runtime configuration Read options Write options Catalog Configuration A catalog is created and named by executing the following query (replace <catalog... -
Collect Information
Before deploying a cluster, you should collect the following information: The fully qualified domain name (FQDN) of each host in your system. The Ambari Cluster Install wizard s...