StreamX 🚀 什么是StreamX 🎉 Features 🏳‍🌈 组成部分 1️⃣ streamx-core 2️⃣ streamx-pump 3️⃣ streamx-console 👻 为什么不是…❓ Apache Zeppelin FlinkX StreamX make stream processing easier!!!...

平台部署 环境要求 注意 Hadoop Kubernetes 编译 & 部署 环境要求 编译打包 1.2.1之前版本 特别注意 1.2.1之后版本 混合打包 特别注意 独立打包 1. 后端编译 2. 前端打包 特别注意 部署后端 初始化表结构 修改配置 新建数据库 streamx 修改连接信息 修改workspace ...

开发环境 安装 Hadoop（可选，YARN Runtime） 本地安装 Hadoop 环境 使用已有 Hadoop 集群 安装 Kubernetes （可选，K8s Runtime） 安装 Flink（可选，Standalone Runtime） 安装 Maven 安装 MySQL 安装 Nodejs 安装配置 StreamX 后端 编译 ...

Flink K8s 集成支持 额外环境要求 集成准备 Kubernetes 连接配置 Kubernetes RBAC 配置 Docker 远程容器服务配置 任务提交 Application 任务发布 Session 任务发布 相关参数配置 Flink K8s 集成支持 StreamX Flink Kubernetes 基于 Flink...

Doris Connector StreamX 方式写入 配置信息 写入doris 提示 Doris Connector Doris 是一款基于大规模并行处理技术的分布式 SQL 数据库，主要面向OLAP场景。 StreamX 基于Doris的stream load 封装了DoirsSink用于向Doris实时写入数据。 StreamX 方...

快速开始 如何使用 部署 DataStream 任务 部署 FlinkSql 任务 任务启动流程 快速开始 如何使用 在上个章节已经详细介绍了一站式平台 streamx-console 的安装, 本章节看看如果用 streamx-console 快速部署运行一个作业, streamx-console 对标准的 Flink 程序 ( 安装...

K8s PVC 资源使用 K8s PVC 资源使用说明 K8s PVC 资源使用 K8s PVC 资源使用说明 当前版本 StreamX Flink-K8s 任务对 PVC 资源（挂载 checkpoint/savepoint/logs 等文件资源）的支持基于 pod-template。 Native-Kubernetes Session 由创建...

Elasticsearch Connector 提示 elastic写入依赖 基于官网的Elasticsearch写入数据 StreamX 写入 Elasticsearch 1. 配置策略和连接信息 2. 写入Elasticsearch 注意事项 其他配置 处理失败的 Elasticsearch 请求 配置内部批量处理器 StreamX配...

Apache Kafka Connector 依赖 Kafka Source (Consumer) 基础消费示例 注意事项 高级配置参数 消费多个Kafka实例 特别注意 消费多个Topic 提示 Topic 发现 特别注意 配置开始消费的位置 指定分区Offset 指定deserializer 返回记录KafkaRecord ...

Clickhouse Connector JDBC 同步写入 常规方式写入 StreamX 方式写入 配置信息 写入clickhouse 提示 HTTP 异步写入 常规方式写入 StreamX 方式写入 异步写入配置及失败恢复组件配置 写入clickhouse 警告 其他配置 Clickhouse Connector Clic...