Scenario: You need to implement a windowed aggregation operation on streaming data in Apache Flink. Which API would you use, and why?

  • DataStream API
  • ProcessFunction API
  • SQL API
  • Table API
You would use the Table API in Apache Flink for implementing a windowed aggregation operation on streaming data. The Table API provides a higher-level abstraction for stream processing, allowing developers to express complex computations using SQL-like queries and operators. It offers built-in support for windowed aggregations, making it convenient for tasks such as calculating aggregates over sliding or tumbling windows efficiently.
Add your answer
Loading...

Leave a comment

Your email address will not be published. Required fields are marked *