Aliyun OSS configs Aliyun OSS Credentials Aliyun OSS Libs In this page, we explain how to get your Hudi spark job to store into Aliyun OSS. Aliyun OSS configs There are two c...
Description Options separator [string] split_field[string] output_fields[array] common options [string] Example Changelog new version Split transform plugin Descript...
rand abs ceil floor round sign rand rand() returns a random floating point number in the range from 0 (inclusive) to 1 (exclusive); i.e.[0,1). The numbers returned follow ...
Description Options field_mapper [config] common options [config] Example Changelog new version FieldMapper transform plugin Description Add input schema and output sc...
Flink Configuration Catalog Configuration A catalog is created and named by executing the following query (replace <catalog_name> with your catalog name and <config_key> =<confi...
Description Options fields [array] common options [string] Example Changelog new version Filter transform plugin Description Filter the field. Options name type ...
Description Options fields [config] common options [string] Example Changelog new version Copy transform plugin Description Copy a field to a new field. Options n...
Using a text editor, open the hosts file on every host in your cluster. For example: vi / etc / hosts Add a line for each host in your cluster. The line should consist of...