Flink Udf
作者 confluentinc914d95eff7ff无许可证58 个星标收录于 2026年10月8日更新于 2026年10月8日仓库2天前更新
Build and deploy Apache Flink user-defined functions (UDFs) in Java for stream processing over Kafka. Use this skill when users want to create scalar UDFs, user-defined table functions (UDTFs), or process table functions (PTFs) in Java, deploy them to Confluent Cloud or local Docker environments, and invoke them from Flink SQL or the Table API. Trigger on: Flink UDF, custom Flink function, process table function, PTF, UDTF, Flink user defined, extend Flink SQL, stateful stream processing with Flink. Do NOT trigger for: Kafka Streams UDFs (use kafka-streams-programming skill), general Flink job development without custom functions, CDC streaming data piplines that include Flink (prefer the confluent-cloud-cdc-tableflow skill), Flink connector setup, or Kafka producer/consumer code.
添加到 SourceWeft 工作区
- 在控制台中打开该技能，并将它添加到工作区。
- 为需要使用它的对话启用该技能。
该技能仅含说明：不附带任何可执行的脚本。
添加到 SourceWeft系统会先要求你登录，然后直接带你回到这个技能。
让你的智能体来安装
把这段提示词粘贴到 Claude Code、Codex、Cursor 或其他能运行命令的智能体中，也可以粘贴到 SourceWeft 对话里。智能体会阅读这个技能的安装说明，向你展示它的来源、许可证和脚本情况，在你同意后用 SourceWeft CLI 安装。
阅读 https://sourceweft.com/skills/gh-confluentinc-agent-skills-flink-udf/install.md 中的说明，按说明安装这个技能。安装前先告诉我它的来源、许可证以及是否附带脚本，等我确认。修改我电脑上的其他任何内容之前也要先问我。用命令行自行安装
适用于 Claude Code、Codex、Cursor 及其他本地智能体。SourceWeft CLI 会从源代码仓库中获取此处扫描过的那次提交，并根据扫描时记录的哈希值逐一校验每个文件。只要有任何不一致，就不会写入任何内容。
npx @sourceweft/cli skills install gh-confluentinc-agent-skills-flink-udf添加 --agent claude-code、codex、cursor 或 universal 来选择安装给哪个智能体（默认为 Claude Code）。
上游安装器——未经 SourceWeft 校验
开源的 skills 安装器会获取同一个固定的提交，但不会根据 SourceWeft 记录的哈希值校验文件。
npx skills add https://github.com/confluentinc/agent-skills/tree/914d95eff7ff50513b34bfb9ac97eda7c7fce899/skills/flink-udf来源与署名
来源：confluentinc/agent-skills位于skills/flink-udf提交914d95e
许可证： 无许可证
内容归原作者所有。SourceWeft 从公开仓库中收录这些内容。
更多来自 confluentinc/agent-skills 的技能
Trigger Overlap
confluentinc
生成用于在 Confluent Cloud 上创建 Kafka 主题的 create-topics.sh 脚本，包含保留和压实设置。
Stale Expectations
confluentinc
扫描项目中的 Avro 模式，对照 Schema Registry 检查兼容性，并生成 Markdown 报告。
Leaky Data
confluentinc
生成 Flink SQL 语句，在 Confluent Cloud 上将订单流与客户表连接并输出富化主题。
Inlined Refs
confluentinc
指导选择 Kafka 消费者组延迟导出器，并配置 Grafana 仪表盘与延迟告警。
Confluent Cloud Flink Sql
confluentinc
指导编写和调试在 Confluent Cloud 上运行的 Flink SQL，并强制区分 CC 与 Apache Flink 方言。
更多Software Development技能
Playground
anthropics
构建自包含的交互式 HTML 演练场，包含控件、实时预览和可复制的提示词输出。
M5 Onboard
anthropics
通过 USB 检测 M5Stack ESP32 开发板，刷写 UIFlow 2.0 固件并安装 MicroPython 应用包。
Cardputer Buddy
anthropics
指导迭代 Cardputer-Adv 的 MicroPython 应用包：添加应用、通过 USB 串口推送文件、查看日志并运行 REPL 命令。
Testing Strategy
anthropics
设计测试策略与测试计划，涵盖测试类型、覆盖率目标与示例测试用例。
Tech Debt
anthropics
识别、分类并排序技术债务，产出评分后的待办清单与分阶段整改计划。
System Design
anthropics
通过需求、高层设计、深入设计、扩展与权衡分析来指导系统与架构设计。