JingsongLi commented on a change in pull request #17673: URL: https://github.com/apache/flink/pull/17673#discussion_r746187390
########## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/window/WindowWTFWithRowSemanticsOperator.java ########## @@ -37,15 +37,16 @@ import static org.apache.flink.util.Preconditions.checkArgument; /** - * The WindowTableFunctionOperator acts as a table-valued function to assign windows for input row. + * The WTFWithRowSemanticsOperator acts as a table-valued function to assign windows for input row. * Output row includes the original columns as well additional 3 columns named {@code window_start}, * {@code window_end}, {@code window_time} to indicate the assigned window. * - * <p>Note: The operator only works for row-time. + * <p>Note: The operator only applies for Window TVF with row semantics (e.g TUMBLE/HOP/CUMULATE) + * instead of set semantics (e.g Session). * - * <p>Note: The operator emits per record instead of at the end of window. + * <p>The operator emits result per record instead of at the end of window. */ -public class WindowTableFunctionOperator extends TableStreamOperator<RowData> +public class WindowWTFWithRowSemanticsOperator extends TableStreamOperator<RowData> Review comment: I think we can keep previous name to keep compatibility. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org