V Badalyan
11/09/2020, 1:03 AMdata claaa D(vtype: string, value: int, dim1 ... dimX)
где dimX - некоторые "классификации, дайменшены)
Собственно я беру этот CSV - прогоняю через скажем 5 фильтров и остается у меня от общем массы по 1% в каждом из этих 5 флоу.
Вопрос. Как эффективно также продолжая 1 проход отфильровать из 5 отдельных фору группу где di1 и dim2 и dim3 у элементов совпадают). Те сделать группировку по разрезу и отсеять где нет полного совпадения....
Завис Пока только смог сделать промежуточную фильтрацию "Явно не войдет" и дальше второй проход уже по (флоу в буфер/канал) каналам в который результат первого цикла. Есть идеи? Как можно не дожидаясь окончание потока получить на текущем результате пересечение и сразу же по нему отдельный поток/корутин .Zimri Leisher
11/09/2020, 1:06 AMV Badalyan
11/09/2020, 1:09 AMZimri Leisher
11/09/2020, 1:15 AMVal Salamakha
11/09/2020, 1:42 AMV Badalyan
11/09/2020, 1:46 AMilya.gorbunov
11/09/2020, 1:55 AMV Badalyan
11/09/2020, 1:57 AMV Badalyan
11/09/2020, 2:00 AM