From 37e3aa0e2667af5734cfd7485a68b96ddf9764bc Mon Sep 17 00:00:00 2001 From: webbrain-one <295484252+webbrain-one@users.noreply.github.com> Date: Tue, 18 Aug 2026 05:36:18 +0300 Subject: [PATCH] docs: improve README --- README.md | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/README.md b/README.md index 59bc1c3..ef08352 100644 --- a/README.md +++ b/README.md @@ -1,4 +1,5 @@ + > 本文基于 Spark 3.1.2 版本 (最新的stable版本) > 可能是全网第一篇中文 Spark 3.x Kafka数据源源码的博文了,基于源码可以自行实现多种数据源增强功能,比如KafkaCluster failover @@ -57,7 +58,6 @@ $ bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server loca 3.1.2 - ``` 3.写一个main方法 @@ -745,6 +745,7 @@ Data Source interfaces in Spark 3.0.0 官方sample Java版 https://github.com/apache/spark/blob/72615bc551adaa238d15a8b43a8f99aaf741c30f/sql/core/src/test/java/test/org/apache/spark/sql/connector/JavaPartitionAwareDataSource.java ``` +本仓库 `src/main/java/org/example` 下提供了 `CustomTableProvider` 等自定义微批数据源示例代码。 - Spark 输入输出源相关接口API V1 V2 多次迭代的原因是什么? ``` 详细视频:- https://www.youtube.com/watch?v=9-eomYXVnvY&ab_channel=Databricks