pyspark/bigdl/util/common.py
def callBigDlFunc(bigdl_type, name, *args):
    """ Call API in PythonBigDL """
    gateway = _get_gateway()
    error = Exception("Cannot find function: %s" % name)
    for jinvoker in JavaCreator.instance(bigdl_type, gateway).value:
        # hasattr(jinvoker, name) always return true here,
        # so you need to invoke the method to check if it exist or not
        try:
            api = getattr(jinvoker, name)
            result = callJavaFunc(api, *args)
        except Exception as e:
            error = e
            if "does not exist" not in str(e):
                raise e
        else:
            return result
    raise error
def callBigDlFunc(bigdl_type, name, *args):
    gateway = _get_gateway()
    error = Exception("Cannot find function: %s" % name)
    for jinvoker in JavaCreator.instance(bigdl_type, gateway).value:
        # hasattr(jinvoker, name) always return true here,
        # so you need to invoke the method to check if it exist or not
        try:
            api = getattr(jinvoker, name)
            result = callJavaFunc(api, *args)
        except Exception as e:
            error = e
            if "does not exist" not in str(e):
                raise e
        else:
            return result
    raise error
def callBigDlFunc ( bigdl_type , name , * args ) : gateway = _get_gateway ( ) error = Exception ( "Cannot find function: %s" % name ) for jinvoker in JavaCreator . instance ( bigdl_type , gateway ) . value : # hasattr(jinvoker, name) always return true here, # so you need to invoke the method to check if it exist or not try : api = getattr ( jinvoker , name ) result = callJavaFunc ( api , * args ) except Exception as e : error = e if "does not exist" not in str ( e ) : raise e else : return result raise error
Call API in PythonBigDL
Call API in PythonBigDL