OCI Configs Configuring the HDFS Connector Libraries Construct an OCI HDFS URI The Oracle Object Storage system provides strongly-consistent operations on all buckets in all ...
HTTP Endpoints Kafka Endpoints Pulsar Endpoints Bring your own implementation Apache Hudi provides the ability to post a callback notification about a write commit. This may b...
always comparator compose construct curry useWith flip groupBy identity invoker nAry once pipe tap always a → (* → a) Parameters valThe value to wrap in a func...
How To Use MySQL-CDC Sink Kafka SeaTunnel supports to interpret cdc record as Debezium-JSON messages publish to mq(kafka) system. This is useful in many cases to leverage this ...
Interoperating with XTable Installation Syncing to XTable Hudi Streamer Extensions Hudi (tables created from 0.14.0 onwards) supports syncing to Iceberg and/or Delta Lake with...
_.castArray(value) Since Arguments Returns Example _.clone(value) Since Arguments Returns Example _.cloneDeep(value) Since Arguments Returns Example _.cloneDeepWi...
Data Setup min Using min() with Lists max stDev stDevP percentileCont percentileDisc count Using count(expression) to return the number of values Counting non-null value...
Support Kudu Version Support Those Engines Key features Description Data Type Mapping Source Options Task Example Simple: Multiple Table Changelog 2.2.0-beta 2022-09-26 N...
_(value) Arguments Returns Example _.chain(value) Since Arguments Returns Example _.tap(value, interceptor) Since Arguments Returns Example _.thru(value, intercept...