-
扩展链接
背景介绍 如何创建扩展链接 扩展链接的使用 背景介绍 在生产实践中，为了更好地管理 Flink作业，总会需要将其与外部服务集成，例如代码仓库、指标监控页面、实时日志记录或 HDFS/OSS 上的检查点/保存点文件夹等。 Streampark 作为一站式 Flink DevOps 平台，如果能够提供以扩展链接的形式集成这些服务的能力，在统一的地方集... -
Configure SAM and Schema Registry Metadata Stores in Postgres
About This Task Steps About This Task If you have already installed MySQL and configured SAM and Schema Registry metadata stores using MySQL, you do not need to configure addit... -
EventMesh Stream
EventMesh Stream Overview of Event Streaming Requirements Functional Requirements Design Details Architecture Design EventMesh-Stream Component Event Event Channel Event End... -
CloudEvents Integration
CloudEvents Integration Introduction Requirements Functional Requirements Performance Requirements Design Details Pluggable Protocols Process of CloudEvents under EventMesh Fo... -
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 - ... -
DataStream Connector
Apache Kafka Connector JDBC Connector ClickHouse Connector Apache Doris Connector Elasticsearch Connector Apache HBase Connector HTTP Connector Redis Connector -
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... -
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 ... -
Hive Distcp
Introduction Configure Hive Distcp Job Source and target metastores Database and tables to copy Target path computation Conflicting table and partitions treatment Deregisterin...
