-
Architecture
Introduction Architecture Overview Unified Interface Runtime Resource Resiliency High Availability & Load Balance Authentication & Authorization Conclusions Introduction K... -
Accumulo Clients
Creating Client Code Creating an Accumulo Client Authentication Writing Data BatchWriter ConditionalWriter Durability Reading Data Scanner Isolated Scanner BatchScanner ... -
任务结构
任务总体存储结构 各任务类型存储结构详解 Shell节点 SQL节点 PROCEDURE[存储过程]节点 SPARK节点 MapReduce(MR)节点 Python节点 Flink节点 HTTP节点 DataX节点 Sqoop节点 条件分支节点 子流程节点 依赖(DEPENDENT)节点 任务总体存储结构 在dolphin... -
应用监控
写在前面 埋点工具 夜莺自身监控 Webapi Server 数据抓取 参考资料 写在前面 应用监控实际要比 OS、中间件的监控更为关键，因为某个 OS 层面的指标异常，比如 CPU 飙高了，未必会影响终端用户的体验，但是应用层面的监控指标出问题，通常就会影响客户的感受、甚至影响客户的付费。 针对应用监控，Google提出了 4 个黄金指... -
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. ... -
Iterators
Instantiation Interface init seek next hasTop getTopKey and getTopValue deepCopy Yielding Interface enableYielding TabletServer invocation of Iterators Isolation Abstra... -
平台安装介绍
目的和范围 目标受众 系统要求 硬件要求 软件要求 安装前准备 下载&&配置flink 引入MySQL依赖包 下载Apache StreamPark™ 安装 初始化系统数据 查看执行StreamPark元数据SQL文件 连接MySQL数据库 && 执行初始化脚本 查看执行结果 Apache StreamPark™配置 配置mysql... -
项目配置
为什么需要配置 flink option property 基础参数 Memory参数 配置总内存 Table app sql 总结 配置在StreamPark 中是非常重要的概念,先说说为什么需要配置 为什么需要配置 开发DataStream 程序,大体流程都可以抽象为以下4步 StreamExecutionEnvironm... -
Design & Concepts
How does Hudi ensure atomicity? Does Hudi extend the Hive table layout? What concurrency control approaches does Hudi adopt? Hudi’s commits are based on transaction start time i... -
Async Queries via Celery
Celery Celery Flower Celery On large analytic databases, it’s common to run queries that execute for minutes or hours. To enable support for long running queries that execute b...
