Big Data Technology & Architecture
Sep 4, 2021 · Big Data
Understanding Time Semantics, Windows, and Process Functions in Apache Flink
This article explains how to define time characteristics, assign timestamps and watermarks, use Flink's window API, implement custom process functions, side outputs, and triggers, and handle late events, providing both Scala and Java code examples for real‑time stream processing.
Apache FlinkProcessFunctionTime Semantics
0 likes · 52 min read