| name | type | null | key | extras | watermark | + -+-+-+-+-+-+ `bidtime` in this tableįlink SQL > desc Bid + -+-+-+-+-+-+ The following shows the syntax of the Window Top-N statement: Otherwise, the optimizer won’t be able to translate the query. Window Top-N can be defined in the same syntax as regular Top-N, see Top-N documentation for more information.īesides that, Window Top-N requires the PARTITION BY clause contains window_start and window_end columns of the relation applied Windowing TVF or Window Aggregation. Besides, Window Top-N could be used with other operations based on Windowing TVF, such as Window Aggregation, Window TopN and Window Join. Usually, Window Top-N is used with Windowing TVF directly. Therefore, window Top-N queries have better performance if users don’t need results updated per record. Moreover, window Top-N purges all intermediate state when no longer needed. Window Top-N is a special Top-N which returns the N smallest or largest values for each window and other partitioned keys.įor streaming queries, unlike regular Top-N on continuous tables, window Top-N does not emit intermediate results but only a final result, the total top N records at the end of the window. We recommend you use the latest stable version. This documentation is for an unreleased version of Apache Flink. Window Top-N follows after Windowing TVF.Window Top-N follows after Window Aggregation.

Hadoop MapReduce compatibility with Flink.Conversions between Table and DataStream.Conversions between PyFlink Table and Pandas DataFrame.

Download windowtop