Tumbling window TVF

Hopping window TVF

Session window TVF

Cumulate window TVF

Sensor watermark declaration

Activity watermark declaration

Energy watermark declaration

Window GROUP BY includes window_start/end

Kafka connector config

Aggregation functions

DESCRIPTOR references correct column

Partition by sensor/user/meter

Extends ScalarFunction

Public eval method

Null handling in scalar

Extends TableFunction

FunctionHint annotation

Collect method usage

Maven shade plugin

Flink dependency provided scope

Python udf decorator

Artifact upload command

CREATE FUNCTION with artifact

LATERAL TABLE usage

Interval join syntax

Temporal join syntax

Lookup join with PROCTIME

Debezium CDC format

CDC primary key

Upsert-kafka connector

Upsert primary key

Deduplication pattern

Watermarks on streams

Currency rates primary key

State TTL consideration

No unbounded regular join

Extends ProcessTableFunction

SET_SEMANTIC_TABLE annotation

StateHint with TTL

ValueState for per-key state

OnTimer annotation

Timer registration

FunctionHint output type

SQL PARTITION BY

SQL uid parameter

SQL on_time DESCRIPTOR

CAST for time parameter

Collect Row output

ConfluentSettings usage

ConfluentTools for results

Statement Set syntax

MATCH_RECOGNIZE structure

System column $rowtime

Compute pool create command

Statement create command

Savepoint workflow

Exception list command

Tumbling window for metrics

Confluent Cloud plugin dependency

No unsupported features