py4j

    1热度

    1回答

    我试图使用pyspark.mllib.stat.KernelDensity这样: data = sc.parallelize([0, 1, 2, 2, 1, 1, 1, 1, 1, 2, 0, 0]) kd = KernelDensity() kd.setSample(data) kd.setBandwidth(3) densities = kd.estimate([-1.0, 2.0,

    1热度

    2回答

    启动Java网关 我能够用在Python我的示例Java程序进行交互,打开我的Java程序,然后使用下面的Python代码: from py4j.java_gateway import JavaGateway gg = JavaGateway() sw = gg.entry_point.getInstance() sw.run() ... 然而,这有缺点是我必须在使用此代码之前以某种方

    0热度

    1回答

    我无法在Anaconda - Spyder中安装Py4j。 我正在使用Windows 32位,Python 3.5和anaconda 4.1。 我收到以下错误: 我试过多种命令,包括 畅达安装py4j 我也运行下面的命令: C:\Users\360529>anaconda search -t conda py4j Using Anaconda API: https://api.anaconda.

    0热度

    2回答

    我配置了Eclipse以便使用Spark和Python进行开发。 我配置了: 1. PyDev与Python解释器 2. PyDev与Spark Python源码 3. PyDev与Spark的环境变量。 这是我的图书馆配置: 这是我的环境配置: 我创建了一个名为CompensationStudy项目,我想运行一个小例子,确保一切顺利。 这是我的代码: from pyspark import Sp

    3热度

    1回答

    我想创建一个Jupyter/IPython扩展来监视Apache Spark作业。 Spark提供了一个REST API。 然而,不是轮询服务器,我希望事件更新通过回调发送。 我正在尝试使用SparkContext.addSparkListener()注册SparkListener。该功能在Python中的PySpark SparkContext对象中不可用。那么我怎样才能从python注册pyt

    2热度

    1回答

    我试图将可变参数从python传递给Java代码。 Java代码: LogDebugCmd.java public class LogDebugCmd implements Command { private Class clazz; private String format; private Object[] args; public LogDebug

    5热度

    3回答

    在Python 3.5 Jupyter环境中运行以下代码时出现以下错误。任何想法是什么导致它? import findspark findspark.init() 错误: IndexError Traceback (most recent call last) <ipython-input-20-2ad2c7679ebc> in <module>() 1 impo

    0热度

    1回答

    我试图用py4j开拓,我可以用它来从Java对象进入蟒蛇的网关。当我尝试使用py4j函数launch_gateway打开网关时,它似乎无法正确连接到我的Java类。但是,当我在命令行中启动我的java类,然后使用JavaGateway在python中连接它时,所有内容都按预期工作。我希望能够使用内置方法,因为我确信我没有考虑py4j设计中已经考虑过的事情,但我只是不确定我做错了什么。 比方说,我想

    0热度

    1回答

    我主要使用Python和Java新增功能。不过,我正在尝试编写一个Java程序,并通过Py4j Python包使其在Python中工作。下面的程序是我从一个例子改编的。我遇到了一个编译错误。你可以点亮一下吗?我很确定这是基本错误。谢谢。 > compile error: incompatible type: SimpleMatrix cannot be converted to String: r

    0热度

    1回答

    我做了一个Java情感分析程序,通过Py4j在Python中使用。我可以在Python中创建Java对象,但尝试访问该方法,它会给出java.lang.NullPointerException。你能帮忙吗?谢谢。 Java代码:它编译正确,运行没有错误。 import java.util.List; import java.util.Properties; import edu.stanfor