Как вычислить систему собственных векторов матрицы с помощью Apache PySpark 2.3

Question

Я должен вычислить собственное значение наименьшей величины и связанный с ним собственный вектор несимметричной матрицы, используя библиотеки PySpark.

Размер is very high and I want the computation to be distributed among the cluster's workers.

The problem is that i didn't find any API to compute eigenvalues in PySpark 2.3 документации .

, которую я определилдва пути, но я хочу их избежать:

1. для переопределения алгоритма декомпозиции собственных значений через QR-код с использованием QRDecomposition, доступного в PySpark API
2. для вычисления собственных значений scala version class, как описано в этот вопрос о переполнении стека

Есть ли более простой или лучший способ, чем последние два?

Я уже знаю существование этого поста, но они концептуально отличаются.