-
Using Flink
CDC Ingestion Bulk Insert Options Index Bootstrap Options How To Use Changelog Mode Options Append Mode Inline Clustering Async Clustering Clustering Plan Strategy Buck... -
FtpFile
Description Key features Options host [string] port [int] user [string] password [string] path [string] connection_mode [string] custom_filename [boolean] file_name_expres... -
Hive
Description Key features Options table_name [string] metastore_uri [string] hdfs_site_path [string] hive_site_path [string] hive.hadoop.conf [map] hive.hadoop.conf-path [str... -
SQL Functions
String Functions ASCII CHAR_LENGTH / LENGTH OCTET_LENGTH CONCAT CONCAT_WS HEXTORAW LOWER / LCASE UPPER / UCASE LEFT RIGHT LOCATE / INSTR / POSITION LPAD RPAD LTRIM RT... -
Config File Encryption And Decryption
Introduction How to use How to implement user-defined encryption and decryption Introduction In most production environments, sensitive configuration items such as passwords a... -
SftpFile
Description Key features Options host [string] port [int] username [string] password [string] path [string] custom_filename [boolean] file_name_expression [string] filenam... -
JDOQL
JDOQL Single-String JDOQL Accessing Fields Data types : literals Operators precedence Concatenation Expressions Example 1 - Use of Explicit Parameters Example 2 - Use of Impl... -
MapReduce
General MapReduce configuration Add Accumulo’s MapReduce API to your dependencies Configure dependencies for your MapReduce job Read input from an Accumulo table Write output t... -
Writes
Writing with SQL INSERT INTO MERGE INTO MERGE INTO syntax INSERT OVERWRITE Overwrite behavior Dynamic overwrite Static overwrite DELETE FROM UPDATE Writing to Branc... -
S3Redshift
Description Key features Options jdbc_url jdbc_user jdbc_password execute_sql path [string] bucket [string] access_key [string] access_secret [string] hadoop_s3_propertie...