暂无搜索历史
在 Spark SQL 中，参与 Join 操作的两张表分别被称为流式表（StreamTable）和构件表（BuildTable），不同表的角色在 Spark ...
GlobalPartitioner 分区器会将上游所有元素都发送到下游的第一个算子实例上(SubTask Id = 0)
由前文我们知道，StreamGraph 表示一个流任务的逻辑拓扑，可以用一个 DAG 来表示（代码实现上没有一个 DAG 结构），DAG 的顶点是 Stream...
javacc 会根据 parser.jj 中定义的相互穿插的 Token、Java 代码来自动生成 org.apache.calcite.sql.parser....
如上，通过 DataStreamSource<OUT> StreamExecutionEnvironment#addSource(SourceFunction<...
包含 distinct 关键字的 aggregation 由 4 个物理执行步骤组成。我们使用以下 query 来介绍：
腾讯 ｜ 产品运营 (已认证)
申请条件：至少有 10 篇或以上符合投稿要求可迁入腾讯云专栏的原创技术文章。
其中 olap_model_6607769716595835175.json 内容如下：
该过程主要封装在 OLAPToEnumerableConverter#implement 中，主要流程如下：
Apche Kylin 是 Hadoop 大数据平台上的一个开源 OLAP 引擎。它采用多维立方体（Cube）预计算技术，可以将某些场景下的大数据 SQL 查询...
Delta Lake 时间旅行允许您查询 Delta Lake 表的旧快照。时间旅行有很多用例，包括：
Source 必须不断地到达数据以进行流式查询。 Source 必须具有单调递增的进度概念，用 offset 表示。 Spark 将定期查询每个 Source ...
学习是从观察触发，听觉是一种观察，视觉是一种观察，也许甚至有更多例例如嗅觉或触觉都是一种观察，从这些观察出发，然后经过我们脑袋的内化转化的过程，最后变成有用的技...
全局限制，最多返回 limitExpr 对应条 records。总是通过 IntegerLiteral#unapply(limitExpr: Expressio...
在《Spark 内存管理的前世今生（上）》中，我们介绍了 UnifiedMemoryManager 是如何管理内存的。然而，UnifiedMemoryManag...
使用 object CurrentOrigin 为 TreeNodes 提供一个可以查找上下文的地方，比如当前正在解析哪行 code。
即上图中的第 9 步中的 executeCodeFunc，用来真正运行代码片段的函数，流程如下
关于Apache Livy（下文简称 livy）是什么以及有什么用，请移步：Livy：基于Apache Spark的REST服务
Livy Session 详解（上） - 简书 一文主要介绍了 session 整体的启动流程并详细分析了 client 端（livy server 端）是如何...
暂未填写公司和职称
暂未填写个人简介
暂未填写学校和专业
暂未填写个人网址
暂未填写所在城市
