-
Distributed publish/subscribe
Topic Java RTopic object implements Publish / Subscribe mechanism based on Redis Pub/Sub or Valkey Pub/Sub . It allows to subscribe on events published with multiple instances o... -
Flink DDL
DDL commands CREATE Catalog Hive catalog This creates an Iceberg catalog named hive_catalog that can be configured using 'catalog-type'='hive' , which loads tables from Hive m... -
DataStream Connector
Apache Kafka Connector JDBC Connector ClickHouse Connector Apache Doris Connector Elasticsearch Connector Apache HBase Connector HTTP Connector Redis Connector -
Daft
Daft Daft is a distributed query engine written in Python and Rust, two fast-growing ecosystems in the data engineering and machine learning industry. It exposes its flavor of t... -
数据流连接器
Apache Kafka Connector JDBC Connector Clickhouse Connector Apache Doris Connector Elasticsearch Connector Apache HBase Connector HTTP Connector Redis Connector -
Transactions
Transactions management RMap , RMapCache , RLocalCachedMap , RSet , RSetCache and RBucket Redisson objects may participant in Transaction with ACID properties. It uses locks for... -
Writing ORC Data
Introduction Hive SerDe Integration Writing to an ORC File Data Flow Extending Gobblin’s SerDe Integration Introduction Gobblin is capable of writing data to ORC files by le... -
AmazonDynamoDB
Description Key Features Options url [string] region [string] accessKeyId [string] secretAccessKey [string] table [string] common options Example Changelog next version ... -
Using Kafka Connect
Try out the new experimental release of Hudi Kafka Connect Sink. Read the ReadMe for full documentation. -
Logic
and isEmpty not or cond ifElse allPass anyPass defaultTo and a → b → a | b Added in v0.1.0 Returns the first argument if it is falsy, otherwise the second argument. ...
