def process_result(self, data, **kwargs):
        run(self.source % "hadoop dfs -rmr %s" % self._manager_dir, quiet=True)
        hadoop_command = OKAPI_COMMAND % {
            "model_class": self._model_java_class,
            "okapi_jar": "%s%s" % (self._okapi_local_repository, self._okapi_jar),
            "max_item_id": self.get_item_len(data, **kwargs),
            "input": self.input,
            "output": self.output,
            "manager_dir": self._manager_dir
        }
        logger.debug("... Execute okapi: %s" % self.source % hadoop_command)
        run(self.source % hadoop_command, quiet=True)
        logger.debug("Done!")
Hask okapi the model
dataset/ETHPy150Open grafos-ml/test.fm/src/testfm/okapi/connector.py/BaseOkapiModel.process_result