暂时未有相关云产品技术能力~
暂无个人介绍
Apache Hudi初探(九)(与spark的结合)--非bulk_insert模式
Apache Hudi初探(八)(与spark的结合)--非bulk_insert模式
Apache Hudi初探(七)(与spark的结合)
Apache Hudi初探(六)(与spark的结合)
Apache Hudi初探(五)(与spark的结合)
Apache Hudi初探(四)(与spark的结合)
Spark 3.1.1遇到的 BroadcastQueryStageExec timeout
Apache Hudi初探(二)(与spark的结合)
Apache Hudi初探(与spark的结合)
数据湖的选型(delta iceberg hudi)以及比对
SPARK中InMemoryFileIndex文件缓存导致的REFRESH TABLE tableName问题
Spark 3.1.1 shuffle fetch 导致shuffle错位的问题
Spark做TPC-DS性能测试
关于jvm范型和scala implicit隐式参数以及classTag[T] typeTag[T]的一点思考
SPARK中metrics是怎么传递的
Delta Lake中CDC的实现
SPARK中关于HighlyCompressedMapStatus的说明(会造成运行时的数据不精确)
FLINK ON K8S 基于Zookeeper和基于K8S原生HA的区别
Flink 基于K8S HA 存在的问题
SPARK中的wholeStageCodegen全代码生成--以aggregate代码生成为例说起(10)
SPARK中的wholeStageCodegen全代码生成--以aggregate代码生成为例说起(9)
SPARK中的wholeStageCodegen全代码生成--以aggregate代码生成为例说起(8)
SPARK中的wholeStageCodegen全代码生成--以aggregate代码生成为例说起(7)
SPARK中的wholeStageCodegen全代码生成--以aggregate代码生成为例说起(5)
SPARK中的wholeStageCodegen全代码生成--GenerateUnsafeProjection.createCode说明
SPARK中的wholeStageCodegen全代码生成--以aggregate代码生成为例说起(4)
SPARK中的wholeStageCodegen全代码生成--以aggregate代码生成为例说起(3)
SPARK中的wholeStageCodegen全代码生成--以aggregate代码生成为例说起(2)
SPARK中的wholeStageCodegen全代码生成--以aggregate代码生成为例说起(1)
DATA AI Summit 2022提及到的对 aggregate 的优化
SPARK中 DS V2 push down(下推)的一些说明
SPARK k8s backend中Executor Rolling(Executor的自动化滚动驱逐)
SPARK Parquet嵌套类型的向量化支持以及列索引(column index)
SPARK闲杂--为什么复用Exchange和subquery
DATA AI Summit 2022提及到的对 aggregate 的优化
SPARK中 DS V2 push down(下推)的一些说明
SPARK k8s backend中Executor Rolling(Executor的自动化滚动驱逐)
SPARK Parquet嵌套类型的向量化支持以及列索引(column index)
SPARK中的FileSourceStrategy,DataSourceStrategy以及DataSourceV2Strategy规则
SPARK最新特性Runtime Filtering(运行时过滤)以及与动态分区裁剪的区别
Spark 中的 Rebalance 操作以及与Repartition操作的区别
Flink 维表异步查询的实现以及问题排查
SPARK 3.1.2 Driver端下载UDF jar包导致磁盘爆满
SPARK的计算向量化-spark本身的向量化
LINK JDBC SQL Connector遇到的类型转换问题
SPARK中 会对Scan的小文件做合并到一个Task去处理么?
SPARK 是怎么清除Shuffle中间结果数据的
SPARK push-based shuffle mapTask是怎么获取ESS列表信息
SPARK SHUFFLE中 ShuffleId BlockManagerId 以及 与ESS(External Shuffle Server)交互
SPARK SQL中 Grouping sets转Expand怎么实现的(逻辑计划级别)