小编Alg*_*ata的帖子

我在Cython中构建一个包.我使用以下作为结构setup.py:

from distutils.core import setup
from distutils.extension import Extension
from Cython.Build import cythonize
import numpy
import scipy

extensions = [
    Extension("xxxxx",["xxxx/xxxxx.pyx"],
    include_dirs=[numpy.get_include(),"."]),
    Extension("nnls",["xxxxx/xxxxx.pyx"],
              include_dirs=[numpy.get_include(),"."]),
]

setup(
    name='xxxxxx',
    version='0.0.0',
    description='''********''',
    url='xxxxxxx',
    author='xxxxx',
    author_email='xxxxx',
    packages=[
        'xxxxx',
    ],
    install_requires=[
        'cython',
        'numpy',
        'scipy',
    ],
    ext_modules=cythonize(extensions),
)

但是,我在Python 3中安装时遇到错误.它在Python 2中工作,但它在Python 3中没有编译,但有以下错误:

动态模块没有定义模块导出功能

我怎么解决这个问题？结构setup.py的原因是这不是编译的原因吗？

我们可以通过哪些方式在 Dask Arrays 中执行项目分配？即使是一个非常简单的项目分配，如：a[0] = 2 也不起作用。

我只想询问具体如何在Spark中成功使用checkpointInterval.:和你是什么在ALS代码此评论的意思https://github.com/apache/spark/blob/master/mllib/src/main/scala/org/apache/spark/mllib/recommendation/ALS.斯卡拉

如果未在[[org.apache.spark.SparkContext]]中设置检查点目录,则忽略此设置.

1. 我们如何设置checkPoint目录？我们可以使用任何与hdfs兼容的目录吗？
2. 是否使用setCheckpointInterval在ALS中实现检查点的正确方法以避免Stack Overflow错误？

编辑:

有没有办法可以在scala中更快地计算上三角矩阵？

/** Returns a vector which consists of the upper triangular elements of a matrix */   
def getUpperTriangle(A: Array[Array[Double]]) = 
{
    var A_ = Seq(0.)
    for (i <- 0 to A.size - 1;j <- 0 to A(0).size - 1)
    {
        if (i <= j){
            A_ = A_ ++ Seq(A(i)(j))
            }
    }
    A_.tail.toArray
}

有没有办法将 dask 数据帧转换为矩阵或二维数组？我知道 dask 还不支持多重索引。我不知道我们如何为此使用 dask 延迟。