DE Mastery GitHub

Apache Flink · FLK-04

Flink SQL & dynamic tables

From your world. your dbt models — the same SELECTs, but as continuously-updating dynamic tables

Practice quiz with instant feedback. For a scored run that counts toward your local progress, use uv run de quiz FLK-04.

1What is the result of a Flink SQL query, conceptually?
2Which RowKinds does an UNBOUNDED GROUP BY aggregation emit when new rows arrive for existing keys? (select all) (select all that apply)
3Which query is APPEND-ONLY (emits only +I)?
4You have an updating query (a GROUP BY that produces -U/+U). Which sink keeps its semantics?
5Flink consumed all input. How does the final materialized state of an updating streaming query relate to the batch answer over the same data?
6What does a -D (DELETE) RowKind in a changelog represent?
7In Flink 2.x SQL, how do you express a one-hour tumbling window over a table t that has the event-time column ts?
8Why grade a ported dbt model on its changelog output and not only on the final printed number?