Deliver In-flight stream processing with Apache Flink on Azure
summary
Confluent Cloud for Apache Flink runs as a fully managed service on Azure Marketplace and demonstrates live stream processing: an automated masking IP addresses action creates a new Kafka topic with masked clickstream events, a JavaScript size-comparison function is packaged as a JavaScript UDF in a JAR and registered for Flink SQL, a continuous query populates a table and performs a temporal join to surface specific brands whose shirts are consistently returned for being too small, and the demo shows the pipeline executing and identifying offending brands in real time.
AI-written summary · about
chapters (6)
- 0:00Introduction to stream processing
- 1:05Data masking with Flink
- 2:28Defining custom logic
- 3:32Analyzing order patterns
- 4:28Identifying problematic brands
- 5:05Conclusion and resources
related talks
43mA Data Streaming Architecture with Apache Flink #bbuzz
34mBeaming Flink to the Cloud @ Netflix
49mscale.bythebay.io: Stephan Ewen, Apache Flink and the Next Wave of Stream Processing Applications
41mBeyond the Hype: When Apache Flink Solves Real Problems
25mOnly SQL: Empower data analysts end-to-end with Flink SQL
40mFrom concept to production; the fastest way to develop & deploy Apache Flink jobs
50mStream Processing Smackdown: Kafka Streams vs. Apache Flink
38mApache Flink: A Very Quick Guide
