У меня есть два искровых потока, в первом идут данные, связанные с продуктами: их цена поставщику, валюта, их описание, идентификатор поставщика. Эти данные обогащаются категорией, угадываемой по анализу описания и цене в долларах. Затем они сохраняются в наборе данных паркета.
Второй поток содержит данные о продаже этих товаров с аукциона, затем стоимость, по которой они были проданы, и дату.
Учитывая тот факт, что продукт может поступить в первый поток сегодня и быть проданным через год, как я могу присоединиться ко второму потоку со всей историей, содержащейся в наборе данных паркета первого потока?
Результат, чтобы было понятно, должен быть средним дневным заработком в ценовом диапазоне ...
