-
Spark Quick Start
Setup Spark 3 Support Matrix Spark Shell/SQL Setup project Create Table Insert data Query data Update data Merging Data Delete data Time Travel Query Incremental query ... -
平台安装介绍
目的和范围 目标受众 系统要求 硬件要求 软件要求 安装前准备 下载&&配置flink 引入MySQL依赖包 下载Apache StreamPark™ 安装 初始化系统数据 查看执行StreamPark元数据SQL文件 连接MySQL数据库 && 执行初始化脚本 查看执行结果 Apache StreamPark™配置 配置mysql... -
AWS
Enabling AWS Integration Spark Flink HTTP Client Configurations URL Connection HTTP Client Configurations Apache HTTP Client Configurations Run Iceberg on AWS Amazon Athena ... -
项目配置
为什么需要配置 flink option property 基础参数 Memory参数 配置总内存 Table app sql 总结 配置在StreamPark 中是非常重要的概念,先说说为什么需要配置 为什么需要配置 开发DataStream 程序,大体流程都可以抽象为以下4步 StreamExecutionEnvironm... -
Redis Connector
Redis Write Dependency Writing Redis the Regular Way 1.Access to source 2. Write to redis Apache StreamPark™ Writes to Redis 1. Configure policy and connection information 2. ... -
Replication
Overview Configuration Site Configuration Instance Configuration Table Configuration Monitoring Work Assignment ReplicaSystems AccumuloReplicaSystem Other Configuration E... -
Writing Tables
What are some ways to write a Hudi table? How is a Hudi writer job deployed? Can I implement my own logic for how input records are merged with record on storage? How do I delet... -
数据质量
概述 任务类型介绍 注意事项 检查逻辑详解 任务操作指南 单表检查之空值检查 检查介绍 界面操作指南 单表检查之及时性检查 检查介绍 界面操作指南 单表检查之字段长度校验 检查介绍 界面操作指南 单表检查之唯一性校验 检查介绍 界面操作指南 单表检查之正则表达式校验 检查介绍 界面操作指南 单表检查之枚举值校验 检查介绍... -
3. Integration with Hive Metastore
Integration with Hive Metastore Requirements Default Behavior Related Configurations Remote Metastore Database Remote Metastore Server Activate Configurations Via kyuubi-defau... -
Architecture
Introduction Architecture Overview Unified Interface Runtime Resource Resiliency High Availability & Load Balance Authentication & Authorization Conclusions Introduction K...
