-
JDBC
Gobblin JDBC writer & publisher Proposed design Requirements Design summary Design detail WriterInitializer JdbcWriterInitializer AvroFieldsPickConverter AvroToJdbcEntryConve... -
Flink Configuration
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... -
Source Common Options
result_table_name [string] parallelism [int] Example Common parameters of source connectors name type required default value result_table_name string no - ... -
Spark Queries
Querying with SQL Querying Mixed-Format table by merge on read Query on change store Querying with DataFrames Querying with SQL Querying Mixed-Format table by merge on read ... -
DataStream Connector
Apache Kafka Connector JDBC Connector ClickHouse Connector Apache Doris Connector Elasticsearch Connector Apache HBase Connector HTTP Connector Redis Connector -
CloudEvents Integration
CloudEvents Integration Introduction Requirements Functional Requirements Performance Requirements Design Details Pluggable Protocols Process of CloudEvents under EventMesh Fo... -
EventMesh Stream
EventMesh Stream Overview of Event Streaming Requirements Functional Requirements Design Details Architecture Design EventMesh-Stream Component Event Event Channel Event End... -
Client-Side Caching
Native implementation Client Side caching is implemented using client tracking listener through RESP3 protocol available in Redis or Valkey. It’s used to speed up read operation... -
RisingWave
RisingWave RisingWave is a Postgres-compatible SQL database designed for real-time event streaming data processing, analysis, and management. It can ingest millions of events per... -
Hive Registration
How Hive Registration Works in Gobblin HiveSpec HiveRegistrationPolicy HiveSerDeManager Predicate and Activity How to Use Hive Registration in Your Gobblin Job Hive Regist...
