def output(self):
        # The corresponding Spark job outputs as GZip format.
        return luigi.contrib.hdfs.HdfsTarget('als-output/', format=luigi.format.Gzip)
Take a player, input, and dictionary of parse results, resolve those
dataset/ETHPy150Open spotify/luigi/examples/spark_als.py/SparkALS.output--crossover with--dataset/ETHPy150Open twisted/imaginary/imaginary/action.py/Action.runEventTransaction