alibaba/feathub

Apply filter before implementation

yunfengzhou-hub opened this issue · 0 comments

In flink_table_builder.py, the method _apply_filter_if_any is applied after transformations. This filtering should be applied before transformations and other logics if possible to reduce computations.

Same for spark_dataframe_builder.py.