def get_result(self):
        logger.debug("... Get result from hadoop")
        okapi_file = run(self.source % "for f in `hadoop dfs -ls %s/part-* | "
                         "awk '{print $8}' | "
                         "sort -V`; "
                         "do hadoop dfs -cat $f; done;" % self.output, quiet=True)
        result = self.output_okapi_to_pandas(okapi_file)
        logger.debug("Done!")
        return result
Return the result from okapi
dataset/ETHPy150Open grafos-ml/test.fm/src/testfm/okapi/connector.py/BaseOkapiModel.get_result