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 field_mapper [config] common options [config] Example Changelog new version FieldMapper transform plugin Description Add input schema and output sc...
add divide multiply product subtract sum modulo add Number → Number → Number Added in v0.1.0 Adds two values. See also subtract . R . add ( 2 , 3 ); //=> ...
Advantages of Migrating to Gobblin Kafka Ingestion Related Job Config Properties Config properties for pulling Kafka topics Config properties for compaction Deployment and Chec...
Metrics Reporting As of 1.1.0 Iceberg supports the MetricsReporter and the MetricsReport APIs. These two APIs allow expressing different metrics reports while supporting a plu...
add divide multiply product subtract sum modulo add Number → Number → Number Added in v0.1.0 Adds two values. See also subtract . R . add ( 2 , 3 ); //=> ...
add divide multiply product subtract sum modulo mathMod de inc negate mean median add Number → Number → Number Added in v0.1.0 Adds two values. See also subtrac...
Description Options fields [array] common options [string] Example Changelog new version Filter transform plugin Description Filter the field. Options name type ...