in pypaimon/py4j/gateway_server.py [0:0]
def _get_classpath(env):
classpath = []
# note that jars are not packaged in test
test_mode = os.environ.get(constants.PYPAIMON4J_TEST_MODE)
if not test_mode or test_mode.lower() != "true":
jars = importlib.resources.files(_JAVA_DEPS_PACKAGE)
one_jar = next(iter(jars.iterdir()), None)
if not one_jar:
raise ValueError("Haven't found necessary python-java-bridge jar, this is unexpected.")
builtin_java_classpath = os.path.join(os.path.dirname(str(one_jar)), '*')
classpath.append(builtin_java_classpath)
# user defined
if constants.PYPAIMON_JAVA_CLASSPATH in env:
classpath.append(env[constants.PYPAIMON_JAVA_CLASSPATH])
# hadoop
hadoop_classpath = _get_hadoop_classpath(env)
if hadoop_classpath is not None:
classpath.append(hadoop_classpath)
return os.pathsep.join(classpath)