У меня есть последовательный lstm keras, который отлично работает на краевом узле кластера hadoop, но мне нужно распределить его для вычисления на подчиненных узлах. Теперь я знаю, что elepha существует, и это было бы здорово, однако я работаю в закрытой среде и у меня нет опций установки conda. У меня есть pyspark, и он настроен правильно. Проблема, с которой я сталкиваюсь, заключается в том, что я не могу создать скользящее окно для использования в качестве входных данных для функций pllpark mllib. Мои данные - это данные датчика временного ряда, и мне нужно сделать 60-секундные снимки, чтобы войти в модель. Любые мысли будут оценены, я знаю, что есть способ сделать это.