dist predict test

fff075d7 · Your Name · 149aa897 · fff075d7
Commit fff075d7 authored Jun 26, 2019 by Your Name
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 1 deletion

dist_predict.py eda/esmm/Model_pipline/dist_predict.py +1 -1

No files found.
--- a/eda/esmm/Model_pipline/dist_predict.py
+++ b/eda/esmm/Model_pipline/dist_predict.py
@@ -269,7 +269,7 @@ if __name__ == "__main__":
        rdd_te_files = spark.sparkContext.parallelize(te_files)
        print("-"*100)
        indices = rdd_te_files.repartition(40).map(lambda x: main(x))
-        # print(indices.take(1))
+        print(indices.take(1))
        print("dist predict nearby")

        te_result_dataframe = spark.createDataFrame(indices.flatMap(lambda x: x.split(";")).map(