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 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...
Custom Catalog It’s possible to read an iceberg table either from an hdfs path or from a hive table. It’s also possible to use a custom metastore in place of hive. The steps to do...
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...