Databricks Spark Structured Streaming
作者 databrickse77e37e8a4da无许可证345 个星标收录于 2026年10月8日更新于 2026年10月8日仓库今天更新
Comprehensive guide to Spark Structured Streaming for production workloads. Use when building streaming pipelines, working with Kafka ingestion, implementing Real-Time Mode (RTM), configuring triggers (processingTime, availableNow), handling stateful operations with watermarks, optimizing checkpoints, performing stream-stream or stream-static joins, writing to multiple sinks, or tuning streaming cost and performance.
添加到 SourceWeft 工作区
- 在控制台中打开该技能，并将它添加到工作区。
- 为需要使用它的对话启用该技能。
该技能仅含说明：不附带任何可执行的脚本。
添加到 SourceWeft系统会先要求你登录，然后直接带你回到这个技能。
让你的智能体来安装
把这段提示词粘贴到 Claude Code、Codex、Cursor 或其他能运行命令的智能体中，也可以粘贴到 SourceWeft 对话里。智能体会阅读这个技能的安装说明，向你展示它的来源、许可证和脚本情况，在你同意后用 SourceWeft CLI 安装。
阅读 https://sourceweft.com/skills/gh-databricks-databricks-agent-skills-databricks-spark-structured-streaming/install.md 中的说明，按说明安装这个技能。安装前先告诉我它的来源、许可证以及是否附带脚本，等我确认。修改我电脑上的其他任何内容之前也要先问我。用命令行自行安装
适用于 Claude Code、Codex、Cursor 及其他本地智能体。SourceWeft CLI 会从源代码仓库中获取此处扫描过的那次提交，并根据扫描时记录的哈希值逐一校验每个文件。只要有任何不一致，就不会写入任何内容。
npx @sourceweft/cli skills install gh-databricks-databricks-agent-skills-databricks-spark-structured-streaming添加 --agent claude-code、codex、cursor 或 universal 来选择安装给哪个智能体（默认为 Claude Code）。
上游安装器——未经 SourceWeft 校验
开源的 skills 安装器会获取同一个固定的提交，但不会根据 SourceWeft 记录的哈希值校验文件。
npx skills add https://github.com/databricks/databricks-agent-skills/tree/e77e37e8a4dabbe2662b680c180bb72a05eca48d/plugins/databricks/claude/skills/databricks-spark-structured-streaming来源与署名
来源：databricks/databricks-agent-skills位于plugins/databricks/claude/skills/databricks-spark-structured-streaming提交e77e37e
许可证： 无许可证
内容归原作者所有。SourceWeft 从公开仓库中收录这些内容。
更多来自 databricks/databricks-agent-skills 的技能
Databricks Unstructured Pdf Generation
databricks
在 Databricks 上构建合成 PDF 文档及配套测试问题，用于 RAG 与 Knowledge Assistant 检索评估。
Databricks Setup Local
databricks
指导通过 CLI 的 setup-local 命令预览、配置或诊断由 uv 管理的本地 Python .venv 环境。
Databricks Dbsql
databricks
面向 Databricks SQL 高级功能的参考指南，涵盖 SQL 脚本、物化视图、地理空间函数和 AI 函数。
Databricks Data Discovery
databricks
通过 Databricks CLI 将 Databricks 数据发现、自然语言数据提问和 SQL 生成路由到 Genie One。
Databricks Dabs
databricks
指导创建、配置、验证、部署和运行 Databricks 声明式自动化捆绑包（DABs）。
Databricks App Design
databricks
为自定义代码 Databricks Apps 的数据界面设计用户体验，并映射到具体的 AppKit 组件。
更多Data & Analytics技能
Content Strategy
anthropics
将 PayPal、QuickBooks 或 Square 的销售数据转化为按优先级排序的 30 天内容简报。
Cash Flow Snapshot
anthropics
根据账簿、支付平台或 CSV 数据生成 30/60/90 天现金流预测，含置信区间和具名风险提示。
Pipeline Review
anthropics
按阶段审查 CRM 销售管道健康状况，标记老化、停滞和高风险商机并检查覆盖率。
Metrics Review
anthropics
审阅产品指标，分析趋势并与目标对比，输出带建议行动的指标记分卡。
Performance Report
anthropics
生成营销表现报告，包含关键指标、趋势分析、成败总结以及按优先级排序的优化建议。
People Report
anthropics
根据人力数据生成人员编制、流失率、多元化和组织健康度等人才分析报告。