У меня есть эти два ключ-значение РДА в искре: rdd1 = [(u'Key1', 4), (u'Key2', 6), (u'Key3', 10)]
rdd2 = [(u'Key1', 4), (u'Key2', 3), (u'Key3', 2)]
И я ищу функцию искры, чтобы получить разделение
Есть ли пример где-нибудь или кто-то может объяснить, как использовать Kinesis Analytics для создания сеансов реального времени. (например, сессия) Упомявлено, что это возможно здесь: https://aws.amaz
Я использую искровую карту, но пространство для хранения продолжает расти. Вопрос 1. MapPartitionsRDD Размер в памяти 9GB х 20 Вы можете уменьшить этот размер? Вопрос 2. And in InternalMapWithStateDSt