def _get_hadoop_classpath()

in pypaimon/py4j/gateway_server.py [0:0]

• 13 lines of code
• 4 McCabe index (conditional complexity)

def _get_hadoop_classpath(env):
    if constants.PYPAIMON_HADOOP_CLASSPATH in env:
        return env[constants.PYPAIMON_HADOOP_CLASSPATH]
    elif 'HADOOP_CLASSPATH' in env:
        return env['HADOOP_CLASSPATH']
    else:
        # use built-in hadoop
        jars = importlib.resources.files(_HADOOP_DEPS_PACKAGE)
        one_jar = next(iter(jars.iterdir()), None)
        if not one_jar:
            raise EnvironmentError(f"The built-in Hadoop environment has been broken, this \
            is unexpected. You can set one of '{constants.PYPAIMON_HADOOP_CLASSPATH}' or \
            'HADOOP_CLASSPATH' to continue.")
        return os.path.join(os.path.dirname(str(one_jar)), '*')