Я хочу отфильтровать статический Dataframe
, используя значения из 3 -4 столбцов потокового Dataframe
. После фильтрации я хочу транслировать его, чтобы можно было выполнять поиск бизнес-логики, которая разработана в UDF
функциях.
Освобождение или использование объединений со статическими и потоковыми данными всегда возвращает потоковые данные, которые я не могу транслировать, пожалуйста, дайте мне знать, как с этим справиться.