Flink Udf
by confluentinc914d95eff7ffNo license58 starsListed Oct 8, 2026Updated Oct 8, 2026Repository updated 2 days ago
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.
Only the file list is public. File contents are available once the skill is installed in a workspace.
| Path | Size | Type |
|---|---|---|
| evals/evals.json | 10.7 KB | application/json |
| references/confluent-cloud-setup.md | 6.6 KB | text/markdown |
| references/dependencies-confluent-cloud.md | 3.3 KB | text/markdown |
| references/dependencies-local.md | 3.5 KB | text/markdown |
| references/local-docker-setup.md | 8.3 KB | text/markdown |
| references/ptf-java-confluent-cloud.md | 10.9 KB | text/markdown |
| references/ptf-java-local.md | 9.9 KB | text/markdown |
| references/udf-udtf-java-confluent-cloud.md | 7.2 KB | text/markdown |
| references/udf-udtf-java-local.md | 6.6 KB | text/markdown |
| SKILL.md | 3.4 KB | text/markdown |
Source and attribution
Source:confluentinc/agent-skillsinskills/flink-udfat commit914d95e
License: No license
Content belongs to its original authors. SourceWeft indexes it from a public repository.
More from confluentinc/agent-skills
Trigger Overlap
confluentinc
Generates a create-topics.sh script for provisioning Confluent Cloud Kafka topics with retention and compaction settings.
Stale Expectations
confluentinc
Scans a project for Avro schemas, checks them against Schema Registry compatibility, and writes a Markdown report.
Leaky Data
confluentinc
Generates a Flink SQL statement that joins an orders stream with a customers table to emit an enriched topic on Confluent Cloud.
Inlined Refs
confluentinc
Guides selection of a Kafka consumer group lag exporter and sets up a Grafana dashboard and lag alerts.
Confluent Cloud Flink Sql
confluentinc
Guides writing and debugging Flink SQL for Confluent Cloud, enforcing the CC-versus-Apache-Flink dialect boundary.
More in Software Development
Playground
anthropics
Builds self-contained interactive HTML playgrounds with controls, live preview, and copyable prompt output.
M5 Onboard
anthropics
Provisions M5Stack ESP32 boards by detecting them on USB, flashing UIFlow 2.0 firmware, and installing a MicroPython app bundle.
Cardputer Buddy
anthropics
Guides iterating on a Cardputer-Adv MicroPython app bundle: adding apps, pushing files over USB-serial, tailing logs, and running REPL commands.
Dpop Adoption
Guides implementation of OAuth 2.0 DPoP (RFC 9449) sender-constrained refresh tokens for Google's OAuth platform.
Gemini Live Api
Generates a Gemini Live API WebSocket client class, tests, docs, and a demo UI for bidirectional streaming.
Gemini Api
Guides use of the Gemini API on Google's Agent Platform with the Gen AI SDK across languages and capabilities.