|
@@ -132,8 +132,8 @@ def read_and_calibration_predict(predict_path: str, is_hdfs=True, step=100) -> [
|
|
|
|
|
|
|
|
|
|
|
|
|
def _main(old_predict_path: str, new_predict_path: str, calibration_file: str, analyse_file: str):
|
|
def _main(old_predict_path: str, new_predict_path: str, calibration_file: str, analyse_file: str):
|
|
|
- old_group_df, old_segment_df = read_and_calibration_predict(old_predict_path, is_hdfs=False)
|
|
|
|
|
- new_group_df, new_segment_df = read_and_calibration_predict(new_predict_path, is_hdfs=False)
|
|
|
|
|
|
|
+ old_group_df, old_segment_df = read_and_calibration_predict(old_predict_path, is_hdfs=True)
|
|
|
|
|
+ new_group_df, new_segment_df = read_and_calibration_predict(new_predict_path, is_hdfs=True)
|
|
|
|
|
|
|
|
# 分段文件保存, 此处保留的最后使用的分段文件，不是所有的分段
|
|
# 分段文件保存, 此处保留的最后使用的分段文件，不是所有的分段
|
|
|
new_segment_df.to_csv(calibration_file, sep='\t', index=False, header=False)
|
|
new_segment_df.to_csv(calibration_file, sep='\t', index=False, header=False)
|
