我可以使用jvm从py4j 的JavaGateway从java.*
导入所有内容
例如:
jvm.java.util.ArrayList
jvm.java.lang.System
random = jvm.java.util.Random()
random.nextInt(3)
或者以这种形式:
from py4j.java_gateway import java_import
java_import(jvm,'java.util.*')
random = jvm.Random()
random.nextInt(3)
我需要导入:
com.typesafe.config.impl.SimpleConfig
com.typesafe.config.ConfigFactory
com.typesafe.config.Config
但它不起作用,我尝试了这些方法:
jvm.com.typesafe.config.impl.SimpleConfig
jvm.java.com.typesafe.config.impl.SimpleConfig
jvm.java.typesafe.config.impl.SimpleConfig
java_import(jvm,'com.typesafe.config.*')
java_import(jvm,'com.typesafe.config.impl.*')
jvm.SimpleConfig
jvm.impl.SimpleConfig
所有退货:py4j.java_gateway.JavaPackage
而不是py4j.java_gateway.JavaClass
作为需要的
我不得不下载JARhttps://repo1.maven.org/maven2/com/typesafe/config/1.4.1/config-1.4.1.jar然后在("spark.jars", jar_path)
中添加JAR