@@ -152,7 +152,7 @@ impl Booster {
152
152
//let num_parallel_tree = 1;
153
153
154
154
// load distributed code checkpoint from rabit
155
- let version = bst . load_rabit_checkpoint ( ) ? ;
155
+ let version = unsafe { xgboost_sys :: RabitVersionNumber ( ) } ;
156
156
debug ! ( "Loaded Rabit checkpoint: version={}" , version) ;
157
157
assert ! ( unsafe { xgboost_sys:: RabitGetWorldSize ( ) != 1 || version == 0 } ) ;
158
158
@@ -171,7 +171,6 @@ impl Booster {
171
171
debug ! ( "Updating in round: {}" , i) ;
172
172
bst. update ( params. dtrain , i) ?;
173
173
}
174
- bst. save_rabit_checkpoint ( ) ?;
175
174
}
176
175
177
176
assert ! ( unsafe { xgboost_sys:: RabitGetWorldSize ( ) == 1 || version == xgboost_sys:: RabitVersionNumber ( ) } ) ;
@@ -328,7 +327,7 @@ impl Booster {
328
327
let name = "default" ;
329
328
let mut eval = self . eval_set ( & [ ( dmat, name) ] , 0 ) ?;
330
329
let mut result = HashMap :: new ( ) ;
331
- eval. remove ( name) . unwrap ( ) . into_iter ( ) . for_each ( |( k, v) | {
330
+ eval. swap_remove ( name) . unwrap ( ) . into_iter ( ) . for_each ( |( k, v) | {
332
331
result. insert ( k. to_owned ( ) , v) ;
333
332
} ) ;
334
333
@@ -564,16 +563,6 @@ impl Booster {
564
563
Ok ( out_vec. join ( "\n " ) )
565
564
}
566
565
567
- pub ( crate ) fn load_rabit_checkpoint ( & self ) -> XGBResult < i32 > {
568
- let mut version = 0 ;
569
- xgb_call ! ( xgboost_sys:: XGBoosterLoadRabitCheckpoint ( self . handle, & mut version) ) ?;
570
- Ok ( version)
571
- }
572
-
573
- pub ( crate ) fn save_rabit_checkpoint ( & self ) -> XGBResult < ( ) > {
574
- xgb_call ! ( xgboost_sys:: XGBoosterSaveRabitCheckpoint ( self . handle) )
575
- }
576
-
577
566
pub fn set_param ( & mut self , name : & str , value : & str ) -> XGBResult < ( ) > {
578
567
let name = ffi:: CString :: new ( name) . unwrap ( ) ;
579
568
let value = ffi:: CString :: new ( value) . unwrap ( ) ;
@@ -742,11 +731,6 @@ mod tests {
742
731
assert ! ( res. is_ok( ) ) ;
743
732
}
744
733
745
- #[ test]
746
- fn load_rabit_version ( ) {
747
- let version = load_test_booster ( ) . load_rabit_checkpoint ( ) . unwrap ( ) ;
748
- assert_eq ! ( version, 0 ) ;
749
- }
750
734
751
735
#[ test]
752
736
fn get_set_attr ( ) {
@@ -841,7 +825,7 @@ mod tests {
841
825
assert_eq ! ( * train_metrics. get( "map@4-" ) . unwrap( ) , 1.0 ) ;
842
826
843
827
let test_metrics = booster. evaluate ( & dmat_test) . unwrap ( ) ;
844
- assert_eq ! ( * test_metrics. get( "logloss" ) . unwrap( ) , 0.006919953 ) ;
828
+ assert_eq ! ( * test_metrics. get( "logloss" ) . unwrap( ) , 0.0069199526 ) ;
845
829
assert_eq ! ( * test_metrics. get( "map@4-" ) . unwrap( ) , 1.0 ) ;
846
830
847
831
let v = booster. predict ( & dmat_test) . unwrap ( ) ;
0 commit comments