Back to Browse

Filtering Data with the Apache Flink® Table API | Apache Flink® Table API

634 views
Feb 6, 2025
6:55

Get started: https://cnfl.io/apache-flink-table-api-module-1 | In this video, we'll show the details of implementing a where clause with the Table API. We'll see how they behave differently with streaming data, especially when updates occur. When building **streaming operations** with the Table API, the **where** clause can apply **filter logic** to the statement. This allows it to return a subset of the data being streamed. However, although the where clause looks similar to the SQL equivalent, when working with streaming data the behavior can differ from what we might expect in a SQL database. Streaming data isn't all available and once. As a result, streaming operations persist over time, emitting new data as they encounter it. Furthermore, when updating a database table, you rarely have to worry about queries that occurred before your update. Streaming operations, because they remain active, require updates to propagate downstream. Use the promo code FLINKTABLEAPIJAVA & CONFLUENTDEV1 to get $25 of free Confluent Cloud usage and skip credit card entry: https://cnfl.io/try-cloud-apache-flink-table-api Promo code details: https://cnfl.io/apache-flink-table-api-promo-code-details RELATED RESOURCES ► Java Create Table Statement in Confluent Cloud - https://cnfl.io/42qh5tZ ► SQL Create Table Statement in Confluent Cloud - https://cnfl.io/4arkgn3 ► Apache Flink 101 course - https://cnfl.io/4j9Usj7 ► Apache Flink SQL course - https://cnfl.io/40ceBfM CHAPTERS 00:00 - Intro 00:19 - How is a where clause written in SQL? 00:49 - How is a where clause written in the Table API? 01:30 - What are some variations of a where clause? 02:15 - Why does a where clause behave differently when working with streaming data? 04:21 - How can data streams support updates to previously seen records? 06:42 - Closing CONNECT Subscribe, if you dare: https://www.youtube.com/@ConfluentDeveloper?sub_confirmation=1 Community Slack: confluentcommunity.slack.com X: https://x.com/confluentinc Linkedin: https://www.linkedin.com/company/confluent GitHub: https://github.com/confluentinc Site: https://developer.confluent.io ABOUT CONFLUENT DEVELOPER Confluent Developer provides comprehensive resources for developers looking to learn about Apache Kafka®, Apache Flink®, Confluent Cloud, Confluent Platform, and any other technology related to the broader Data Streaming Platform. Content on Confluent Developer includes courses, getting started guides, topical deep-dives, patterns, tutorials, and listings of community events. Learn more at https://developer.confluent.io. #apachekafka #apacheflink #confluent

Download

1 formats

Video Formats

360pmp412.8 MB

Right-click 'Download' and select 'Save Link As' if the file opens in a new tab.

Filtering Data with the Apache Flink® Table API | Apache Flink® Table API | NatokHD