"vscode:/vscode.git/clone" did not exist on "ca85b6795002cc0c74d8e97d19fee88ca6ecc98e"
engine.py 33.2 KB
Newer Older
wxchan's avatar
wxchan committed
1
# coding: utf-8
2
"""Library with training routines of LightGBM."""
wxchan's avatar
wxchan committed
3
import collections
4
import copy
5
import json
wxchan's avatar
wxchan committed
6
from operator import attrgetter
7
from pathlib import Path
8
from typing import Any, Callable, Dict, Iterable, List, Optional, Tuple, Union
9

wxchan's avatar
wxchan committed
10
import numpy as np
11

wxchan's avatar
wxchan committed
12
from . import callback
13
from .basic import (Booster, Dataset, LightGBMError, _choose_param_value, _ConfigAliases, _InnerPredictor,
14
15
16
                    _LGBM_BoosterEvalMethodResultType, _LGBM_CategoricalFeatureConfiguration,
                    _LGBM_CustomObjectiveFunction, _LGBM_EvalFunctionResultType, _LGBM_FeatureNameConfiguration,
                    _log_warning)
17
from .compat import SKLEARN_INSTALLED, _LGBMBaseCrossValidator, _LGBMGroupKFold, _LGBMStratifiedKFold
wxchan's avatar
wxchan committed
18

19
20
21
22
23
24
25
__all__ = [
    'cv',
    'CVBooster',
    'train',
]


26
27
28
29
30
31
32
33
34
_LGBM_CustomMetricFunction = Union[
    Callable[
        [np.ndarray, Dataset],
        _LGBM_EvalFunctionResultType,
    ],
    Callable[
        [np.ndarray, Dataset],
        List[_LGBM_EvalFunctionResultType]
    ],
35
]
wxchan's avatar
wxchan committed
36

37
38
39
40
41
_LGBM_PreprocFunction = Callable[
    [Dataset, Dataset, Dict[str, Any]],
    Tuple[Dataset, Dataset, Dict[str, Any]]
]

42
43
44
45
46
47
48
49
50

def train(
    params: Dict[str, Any],
    train_set: Dataset,
    num_boost_round: int = 100,
    valid_sets: Optional[List[Dataset]] = None,
    valid_names: Optional[List[str]] = None,
    feval: Optional[Union[_LGBM_CustomMetricFunction, List[_LGBM_CustomMetricFunction]]] = None,
    init_model: Optional[Union[str, Path, Booster]] = None,
51
52
    feature_name: _LGBM_FeatureNameConfiguration = 'auto',
    categorical_feature: _LGBM_CategoricalFeatureConfiguration = 'auto',
53
54
55
    keep_training_booster: bool = False,
    callbacks: Optional[List[Callable]] = None
) -> Booster:
56
    """Perform the training with given parameters.
wxchan's avatar
wxchan committed
57
58
59
60

    Parameters
    ----------
    params : dict
61
62
        Parameters for training. Values passed through ``params`` take precedence over those
        supplied via arguments.
Guolin Ke's avatar
Guolin Ke committed
63
    train_set : Dataset
64
65
        Data to be trained on.
    num_boost_round : int, optional (default=100)
wxchan's avatar
wxchan committed
66
        Number of boosting iterations.
67
    valid_sets : list of Dataset, or None, optional (default=None)
68
        List of data to be evaluated on during training.
69
    valid_names : list of str, or None, optional (default=None)
70
        Names of ``valid_sets``.
71
    feval : callable, list of callable, or None, optional (default=None)
wxchan's avatar
wxchan committed
72
        Customized evaluation function.
Akshita Dixit's avatar
Akshita Dixit committed
73
        Each evaluation function should accept two parameters: preds, eval_data,
74
        and return (eval_name, eval_result, is_higher_better) or list of such tuples.
75

76
            preds : numpy 1-D array or numpy 2-D array (for multi-class task)
77
                The predicted values.
78
                For multi-class task, preds are numpy 2-D array of shape = [n_samples, n_classes].
79
                If custom objective function is used, predicted values are returned before any transformation,
80
                e.g. they are raw margin instead of probability of positive class for binary task in this case.
Akshita Dixit's avatar
Akshita Dixit committed
81
            eval_data : Dataset
82
                A ``Dataset`` to evaluate.
83
            eval_name : str
84
                The name of evaluation function (without whitespaces).
85
86
87
88
89
            eval_result : float
                The eval result.
            is_higher_better : bool
                Is eval result higher better, e.g. AUC is ``is_higher_better``.

90
91
        To ignore the default metric corresponding to the used objective,
        set the ``metric`` parameter to the string ``"None"`` in ``params``.
92
    init_model : str, pathlib.Path, Booster or None, optional (default=None)
93
        Filename of LightGBM model or Booster instance used for continue training.
94
    feature_name : list of str, or 'auto', optional (default="auto")
95
96
        Feature names.
        If 'auto' and data is pandas DataFrame, data columns names are used.
97
    categorical_feature : list of str or int, or 'auto', optional (default="auto")
98
99
        Categorical features.
        If list of int, interpreted as indices.
100
        If list of str, interpreted as feature names (need to specify ``feature_name`` as well).
101
        If 'auto' and data is pandas DataFrame, pandas unordered categorical columns are used.
102
        All values in categorical features will be cast to int32 and thus should be less than int32 max value (2147483647).
103
        Large values could be memory consuming. Consider using consecutive integers starting from zero.
104
        All negative values in categorical features will be treated as missing values.
105
        The output cannot be monotonically constrained with respect to a categorical feature.
106
        Floating point numbers in categorical features will be rounded towards 0.
107
108
109
    keep_training_booster : bool, optional (default=False)
        Whether the returned Booster will be used to keep training.
        If False, the returned value will be converted into _InnerPredictor before returning.
110
        This means you won't be able to use ``eval``, ``eval_train`` or ``eval_valid`` methods of the returned Booster.
111
112
        When your model is very large and cause the memory error,
        you can try to set this param to ``True`` to avoid the model conversion performed during the internal call of ``model_to_string``.
113
        You can still use _InnerPredictor as ``init_model`` for future continue training.
114
    callbacks : list of callable, or None, optional (default=None)
115
        List of callback functions that are applied at each iteration.
116
        See Callbacks in Python API for more information.
wxchan's avatar
wxchan committed
117

118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
    Note
    ----
    A custom objective function can be provided for the ``objective`` parameter.
    It should accept two parameters: preds, train_data and return (grad, hess).

        preds : numpy 1-D array or numpy 2-D array (for multi-class task)
            The predicted values.
            Predicted values are returned before any transformation,
            e.g. they are raw margin instead of probability of positive class for binary task.
        train_data : Dataset
            The training dataset.
        grad : numpy 1-D array or numpy 2-D array (for multi-class task)
            The value of the first order derivative (gradient) of the loss
            with respect to the elements of preds for each sample point.
        hess : numpy 1-D array or numpy 2-D array (for multi-class task)
            The value of the second order derivative (Hessian) of the loss
            with respect to the elements of preds for each sample point.

    For multi-class task, preds are numpy 2-D array of shape = [n_samples, n_classes],
    and grad and hess should be returned in the same format.

wxchan's avatar
wxchan committed
139
140
    Returns
    -------
141
142
    booster : Booster
        The trained Booster model.
wxchan's avatar
wxchan committed
143
    """
144
    # create predictor first
145
    params = copy.deepcopy(params)
146
147
148
149
150
    params = _choose_param_value(
        main_param_name='objective',
        params=params,
        default_value=None
    )
151
    fobj: Optional[_LGBM_CustomObjectiveFunction] = None
152
153
154
    if callable(params["objective"]):
        fobj = params["objective"]
        params["objective"] = 'none'
155
    for alias in _ConfigAliases.get("num_iterations"):
156
        if alias in params:
157
            num_boost_round = params.pop(alias)
158
            _log_warning(f"Found `{alias}` in params. Will use it instead of argument")
159
    params["num_iterations"] = num_boost_round
160
161
162
163
164
165
166
167
    # setting early stopping via global params should be possible
    params = _choose_param_value(
        main_param_name="early_stopping_round",
        params=params,
        default_value=None
    )
    if params["early_stopping_round"] is None:
        params.pop("early_stopping_round")
168
    first_metric_only = params.get('first_metric_only', False)
169

170
171
    if num_boost_round <= 0:
        raise ValueError("num_boost_round should be greater than zero.")
172
    predictor: Optional[_InnerPredictor] = None
173
    if isinstance(init_model, (str, Path)):
174
        predictor = _InnerPredictor(model_file=init_model, pred_parameter=params)
wxchan's avatar
wxchan committed
175
    elif isinstance(init_model, Booster):
176
        predictor = init_model._to_predictor(dict(init_model.params, **params))
177
    init_iteration = predictor.num_total_iteration if predictor is not None else 0
178
    # check dataset
Guolin Ke's avatar
Guolin Ke committed
179
    if not isinstance(train_set, Dataset):
180
        raise TypeError("Training only accepts Dataset object")
Guolin Ke's avatar
Guolin Ke committed
181

182
183
184
185
    train_set._update_params(params) \
             ._set_predictor(predictor) \
             .set_feature_name(feature_name) \
             .set_categorical_feature(categorical_feature)
Guolin Ke's avatar
Guolin Ke committed
186

wxchan's avatar
wxchan committed
187
188
    is_valid_contain_train = False
    train_data_name = "training"
Guolin Ke's avatar
Guolin Ke committed
189
    reduced_valid_sets = []
wxchan's avatar
wxchan committed
190
    name_valid_sets = []
191
    if valid_sets is not None:
Guolin Ke's avatar
Guolin Ke committed
192
193
        if isinstance(valid_sets, Dataset):
            valid_sets = [valid_sets]
194
        if isinstance(valid_names, str):
wxchan's avatar
wxchan committed
195
            valid_names = [valid_names]
Guolin Ke's avatar
Guolin Ke committed
196
        for i, valid_data in enumerate(valid_sets):
197
            # reduce cost for prediction training data
Guolin Ke's avatar
Guolin Ke committed
198
            if valid_data is train_set:
wxchan's avatar
wxchan committed
199
200
201
202
                is_valid_contain_train = True
                if valid_names is not None:
                    train_data_name = valid_names[i]
                continue
Guolin Ke's avatar
Guolin Ke committed
203
            if not isinstance(valid_data, Dataset):
204
                raise TypeError("Training only accepts Dataset object")
Nikita Titov's avatar
Nikita Titov committed
205
            reduced_valid_sets.append(valid_data._update_params(params).set_reference(train_set))
206
            if valid_names is not None and len(valid_names) > i:
wxchan's avatar
wxchan committed
207
208
                name_valid_sets.append(valid_names[i])
            else:
209
                name_valid_sets.append(f'valid_{i}')
210
    # process callbacks
211
    if callbacks is None:
212
        callbacks_set = set()
wxchan's avatar
wxchan committed
213
214
215
    else:
        for i, cb in enumerate(callbacks):
            cb.__dict__.setdefault('order', i - len(callbacks))
216
        callbacks_set = set(callbacks)
wxchan's avatar
wxchan committed
217

218
219
220
    if "early_stopping_round" in params:
        callbacks_set.add(
            callback.early_stopping(
221
                stopping_rounds=params["early_stopping_round"],  # type: ignore[arg-type]
222
223
224
225
226
227
228
229
                first_metric_only=first_metric_only,
                verbose=_choose_param_value(
                    main_param_name="verbosity",
                    params=params,
                    default_value=1
                ).pop("verbosity") > 0
            )
        )
230

231
232
233
234
    callbacks_before_iter_set = {cb for cb in callbacks_set if getattr(cb, 'before_iteration', False)}
    callbacks_after_iter_set = callbacks_set - callbacks_before_iter_set
    callbacks_before_iter = sorted(callbacks_before_iter_set, key=attrgetter('order'))
    callbacks_after_iter = sorted(callbacks_after_iter_set, key=attrgetter('order'))
wxchan's avatar
wxchan committed
235

236
    # construct booster
237
238
239
240
    try:
        booster = Booster(params=params, train_set=train_set)
        if is_valid_contain_train:
            booster.set_train_data_name(train_data_name)
241
        for valid_set, name_valid_set in zip(reduced_valid_sets, name_valid_sets):
242
243
244
245
246
            booster.add_valid(valid_set, name_valid_set)
    finally:
        train_set._reverse_update_params()
        for valid_set in reduced_valid_sets:
            valid_set._reverse_update_params()
247
    booster.best_iteration = 0
wxchan's avatar
wxchan committed
248

249
    # start training
250
    for i in range(init_iteration, init_iteration + num_boost_round):
wxchan's avatar
wxchan committed
251
252
        for cb in callbacks_before_iter:
            cb(callback.CallbackEnv(model=booster,
253
                                    params=params,
wxchan's avatar
wxchan committed
254
                                    iteration=i,
255
256
                                    begin_iteration=init_iteration,
                                    end_iteration=init_iteration + num_boost_round,
wxchan's avatar
wxchan committed
257
258
259
260
                                    evaluation_result_list=None))

        booster.update(fobj=fobj)

261
        evaluation_result_list: List[_LGBM_BoosterEvalMethodResultType] = []
wxchan's avatar
wxchan committed
262
        # check evaluation result.
263
        if valid_sets is not None:
wxchan's avatar
wxchan committed
264
265
266
267
268
269
            if is_valid_contain_train:
                evaluation_result_list.extend(booster.eval_train(feval))
            evaluation_result_list.extend(booster.eval_valid(feval))
        try:
            for cb in callbacks_after_iter:
                cb(callback.CallbackEnv(model=booster,
270
                                        params=params,
wxchan's avatar
wxchan committed
271
                                        iteration=i,
272
273
                                        begin_iteration=init_iteration,
                                        end_iteration=init_iteration + num_boost_round,
wxchan's avatar
wxchan committed
274
                                        evaluation_result_list=evaluation_result_list))
275
276
        except callback.EarlyStopException as earlyStopException:
            booster.best_iteration = earlyStopException.best_iteration + 1
wxchan's avatar
wxchan committed
277
            evaluation_result_list = earlyStopException.best_score
wxchan's avatar
wxchan committed
278
            break
279
    booster.best_score = collections.defaultdict(collections.OrderedDict)
wxchan's avatar
wxchan committed
280
281
    for dataset_name, eval_name, score, _ in evaluation_result_list:
        booster.best_score[dataset_name][eval_name] = score
282
    if not keep_training_booster:
283
        booster.model_from_string(booster.model_to_string()).free_dataset()
wxchan's avatar
wxchan committed
284
285
286
    return booster


287
class CVBooster:
288
289
    """CVBooster in LightGBM.

290
    Auxiliary data structure to hold and redirect all boosters of ``cv()`` function.
291
    This class has the same methods as Booster class.
292
293
294
295
296
297
    All method calls, except for the following methods, are actually performed for underlying Boosters and
    then all returned results are returned in a list.

    - ``model_from_string()``
    - ``model_to_string()``
    - ``save_model()``
298
299
300
301
302
303
304
305

    Attributes
    ----------
    boosters : list of Booster
        The list of underlying fitted models.
    best_iteration : int
        The best iteration of fitted model.
    """
306

307
308
309
310
    def __init__(
        self,
        model_file: Optional[Union[str, Path]] = None
    ):
311
312
        """Initialize the CVBooster.

313
314
315
316
        Parameters
        ----------
        model_file : str, pathlib.Path or None, optional (default=None)
            Path to the CVBooster model file.
317
        """
318
        self.boosters: List[Booster] = []
319
        self.best_iteration = -1
320

321
322
323
324
        if model_file is not None:
            with open(model_file, "r") as file:
                self._from_dict(json.load(file))

325
    def _append(self, booster: Booster) -> None:
326
        """Add a booster to CVBooster."""
327
328
        self.boosters.append(booster)

329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
    def _from_dict(self, models: Dict[str, Any]) -> None:
        """Load CVBooster from dict."""
        self.best_iteration = models["best_iteration"]
        self.boosters = []
        for model_str in models["boosters"]:
            self._append(Booster(model_str=model_str))

    def _to_dict(self, num_iteration: Optional[int], start_iteration: int, importance_type: str) -> Dict[str, Any]:
        """Serialize CVBooster to dict."""
        models_str = []
        for booster in self.boosters:
            models_str.append(booster.model_to_string(num_iteration=num_iteration, start_iteration=start_iteration,
                                                      importance_type=importance_type))
        return {"boosters": models_str, "best_iteration": self.best_iteration}

344
    def __getattr__(self, name: str) -> Callable[[Any, Any], List[Any]]:
345
        """Redirect methods call of CVBooster."""
346
        def handler_function(*args: Any, **kwargs: Any) -> List[Any]:
347
            """Call methods with each booster, and concatenate their results."""
348
349
350
351
            ret = []
            for booster in self.boosters:
                ret.append(getattr(booster, name)(*args, **kwargs))
            return ret
352
        return handler_function
wxchan's avatar
wxchan committed
353

354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
    def __getstate__(self) -> Dict[str, Any]:
        return vars(self)

    def __setstate__(self, state: Dict[str, Any]) -> None:
        vars(self).update(state)

    def model_from_string(self, model_str: str) -> "CVBooster":
        """Load CVBooster from a string.

        Parameters
        ----------
        model_str : str
            Model will be loaded from this string.

        Returns
        -------
        self : CVBooster
            Loaded CVBooster object.
        """
        self._from_dict(json.loads(model_str))
        return self

    def model_to_string(
        self,
        num_iteration: Optional[int] = None,
        start_iteration: int = 0,
        importance_type: str = 'split'
    ) -> str:
        """Save CVBooster to JSON string.

        Parameters
        ----------
        num_iteration : int or None, optional (default=None)
            Index of the iteration that should be saved.
            If None, if the best iteration exists, it is saved; otherwise, all iterations are saved.
            If <= 0, all iterations are saved.
        start_iteration : int, optional (default=0)
            Start index of the iteration that should be saved.
        importance_type : str, optional (default="split")
            What type of feature importance should be saved.
            If "split", result contains numbers of times the feature is used in a model.
            If "gain", result contains total gains of splits which use the feature.

        Returns
        -------
        str_repr : str
            JSON string representation of CVBooster.
        """
        return json.dumps(self._to_dict(num_iteration, start_iteration, importance_type))

    def save_model(
        self,
        filename: Union[str, Path],
        num_iteration: Optional[int] = None,
        start_iteration: int = 0,
        importance_type: str = 'split'
    ) -> "CVBooster":
        """Save CVBooster to a file as JSON text.

        Parameters
        ----------
        filename : str or pathlib.Path
            Filename to save CVBooster.
        num_iteration : int or None, optional (default=None)
            Index of the iteration that should be saved.
            If None, if the best iteration exists, it is saved; otherwise, all iterations are saved.
            If <= 0, all iterations are saved.
        start_iteration : int, optional (default=0)
            Start index of the iteration that should be saved.
        importance_type : str, optional (default="split")
            What type of feature importance should be saved.
            If "split", result contains numbers of times the feature is used in a model.
            If "gain", result contains total gains of splits which use the feature.

        Returns
        -------
        self : CVBooster
            Returns self.
        """
        with open(filename, "w") as file:
            json.dump(self._to_dict(num_iteration, start_iteration, importance_type), file)

        return self

438

439
440
441
442
443
444
def _make_n_folds(
    full_data: Dataset,
    folds: Optional[Union[Iterable[Tuple[np.ndarray, np.ndarray]], _LGBMBaseCrossValidator]],
    nfold: int,
    params: Dict[str, Any],
    seed: int,
445
446
447
448
    fpreproc: Optional[_LGBM_PreprocFunction],
    stratified: bool,
    shuffle: bool,
    eval_train_metric: bool
449
) -> CVBooster:
450
    """Make a n-fold list of Booster from random indices."""
wxchan's avatar
wxchan committed
451
452
    full_data = full_data.construct()
    num_data = full_data.num_data()
453
    if folds is not None:
454
455
456
457
458
459
        if not hasattr(folds, '__iter__') and not hasattr(folds, 'split'):
            raise AttributeError("folds should be a generator or iterator of (train_idx, test_idx) tuples "
                                 "or scikit-learn splitter object with split method")
        if hasattr(folds, 'split'):
            group_info = full_data.get_group()
            if group_info is not None:
460
                group_info = np.array(group_info, dtype=np.int32, copy=False)
461
                flatted_group = np.repeat(range(len(group_info)), repeats=group_info)
462
            else:
463
                flatted_group = np.zeros(num_data, dtype=np.int32)
464
            folds = folds.split(X=np.empty(num_data), y=full_data.get_label(), groups=flatted_group)
wxchan's avatar
wxchan committed
465
    else:
466
467
468
        if any(params.get(obj_alias, "") in {"lambdarank", "rank_xendcg", "xendcg",
                                             "xe_ndcg", "xe_ndcg_mart", "xendcg_mart"}
               for obj_alias in _ConfigAliases.get("objective")):
wxchan's avatar
wxchan committed
469
            if not SKLEARN_INSTALLED:
470
                raise LightGBMError('scikit-learn is required for ranking cv')
471
            # ranking task, split according to groups
472
            group_info = np.array(full_data.get_group(), dtype=np.int32, copy=False)
473
            flatted_group = np.repeat(range(len(group_info)), repeats=group_info)
474
            group_kfold = _LGBMGroupKFold(n_splits=nfold)
475
            folds = group_kfold.split(X=np.empty(num_data), groups=flatted_group)
wxchan's avatar
wxchan committed
476
477
        elif stratified:
            if not SKLEARN_INSTALLED:
478
                raise LightGBMError('scikit-learn is required for stratified cv')
479
            skf = _LGBMStratifiedKFold(n_splits=nfold, shuffle=shuffle, random_state=seed)
480
            folds = skf.split(X=np.empty(num_data), y=full_data.get_label())
extremin's avatar
extremin committed
481
        else:
wxchan's avatar
wxchan committed
482
483
484
485
486
            if shuffle:
                randidx = np.random.RandomState(seed).permutation(num_data)
            else:
                randidx = np.arange(num_data)
            kstep = int(num_data / nfold)
487
488
489
            test_id = [randidx[i: i + kstep] for i in range(0, num_data, kstep)]
            train_id = [np.concatenate([test_id[i] for i in range(nfold) if k != i]) for k in range(nfold)]
            folds = zip(train_id, test_id)
wxchan's avatar
wxchan committed
490

491
    ret = CVBooster()
wxchan's avatar
wxchan committed
492
    for train_idx, test_idx in folds:
493
494
        train_set = full_data.subset(sorted(train_idx))
        valid_set = full_data.subset(sorted(test_idx))
wxchan's avatar
wxchan committed
495
496
        # run preprocessing on the data set if needed
        if fpreproc is not None:
wxchan's avatar
wxchan committed
497
            train_set, valid_set, tparam = fpreproc(train_set, valid_set, params.copy())
wxchan's avatar
wxchan committed
498
        else:
wxchan's avatar
wxchan committed
499
            tparam = params
500
        cvbooster = Booster(tparam, train_set)
501
502
        if eval_train_metric:
            cvbooster.add_valid(train_set, 'train')
503
        cvbooster.add_valid(valid_set, 'valid')
504
        ret._append(cvbooster)
wxchan's avatar
wxchan committed
505
506
    return ret

wxchan's avatar
wxchan committed
507

508
509
510
def _agg_cv_result(
    raw_results: List[List[Tuple[str, str, float, bool]]]
) -> List[Tuple[str, str, float, bool, float]]:
511
    """Aggregate cross-validation results."""
512
513
    cvmap: Dict[str, List[float]] = collections.OrderedDict()
    metric_type: Dict[str, bool] = {}
wxchan's avatar
wxchan committed
514
515
    for one_result in raw_results:
        for one_line in one_result:
516
            key = f"{one_line[0]} {one_line[1]}"
517
            metric_type[key] = one_line[3]
518
            cvmap.setdefault(key, [])
519
            cvmap[key].append(one_line[2])
wxchan's avatar
wxchan committed
520
    return [('cv_agg', k, np.mean(v), metric_type[k], np.std(v)) for k, v in cvmap.items()]
wxchan's avatar
wxchan committed
521

wxchan's avatar
wxchan committed
522

523
524
525
526
527
528
529
530
531
532
533
def cv(
    params: Dict[str, Any],
    train_set: Dataset,
    num_boost_round: int = 100,
    folds: Optional[Union[Iterable[Tuple[np.ndarray, np.ndarray]], _LGBMBaseCrossValidator]] = None,
    nfold: int = 5,
    stratified: bool = True,
    shuffle: bool = True,
    metrics: Optional[Union[str, List[str]]] = None,
    feval: Optional[Union[_LGBM_CustomMetricFunction, List[_LGBM_CustomMetricFunction]]] = None,
    init_model: Optional[Union[str, Path, Booster]] = None,
534
535
    feature_name: _LGBM_FeatureNameConfiguration = 'auto',
    categorical_feature: _LGBM_CategoricalFeatureConfiguration = 'auto',
536
537
538
539
540
541
    fpreproc: Optional[_LGBM_PreprocFunction] = None,
    seed: int = 0,
    callbacks: Optional[List[Callable]] = None,
    eval_train_metric: bool = False,
    return_cvbooster: bool = False
) -> Dict[str, Any]:
Andrew Ziem's avatar
Andrew Ziem committed
542
    """Perform the cross-validation with given parameters.
wxchan's avatar
wxchan committed
543
544
545
546

    Parameters
    ----------
    params : dict
547
548
        Parameters for training. Values passed through ``params`` take precedence over those
        supplied via arguments.
Guolin Ke's avatar
Guolin Ke committed
549
    train_set : Dataset
550
        Data to be trained on.
551
    num_boost_round : int, optional (default=100)
wxchan's avatar
wxchan committed
552
        Number of boosting iterations.
553
    folds : generator or iterator of (train_idx, test_idx) tuples, scikit-learn splitter object or None, optional (default=None)
554
        If generator or iterator, it should yield the train and test indices for each fold.
555
        If object, it should be one of the scikit-learn splitter classes
556
        (https://scikit-learn.org/stable/modules/classes.html#splitter-classes)
557
        and have ``split`` method.
558
        This argument has highest priority over other data split arguments.
559
    nfold : int, optional (default=5)
wxchan's avatar
wxchan committed
560
        Number of folds in CV.
561
562
    stratified : bool, optional (default=True)
        Whether to perform stratified sampling.
563
    shuffle : bool, optional (default=True)
564
        Whether to shuffle before splitting data.
565
    metrics : str, list of str, or None, optional (default=None)
566
567
        Evaluation metrics to be monitored while CV.
        If not None, the metric in ``params`` will be overridden.
568
    feval : callable, list of callable, or None, optional (default=None)
569
        Customized evaluation function.
570
        Each evaluation function should accept two parameters: preds, eval_data,
571
        and return (eval_name, eval_result, is_higher_better) or list of such tuples.
572

573
            preds : numpy 1-D array or numpy 2-D array (for multi-class task)
574
                The predicted values.
575
                For multi-class task, preds are numpy 2-D array of shape = [n_samples, n_classes].
576
                If custom objective function is used, predicted values are returned before any transformation,
577
                e.g. they are raw margin instead of probability of positive class for binary task in this case.
578
579
            eval_data : Dataset
                A ``Dataset`` to evaluate.
580
            eval_name : str
Andrew Ziem's avatar
Andrew Ziem committed
581
                The name of evaluation function (without whitespace).
582
583
584
585
586
            eval_result : float
                The eval result.
            is_higher_better : bool
                Is eval result higher better, e.g. AUC is ``is_higher_better``.

587
588
        To ignore the default metric corresponding to the used objective,
        set ``metrics`` to the string ``"None"``.
589
    init_model : str, pathlib.Path, Booster or None, optional (default=None)
590
        Filename of LightGBM model or Booster instance used for continue training.
591
    feature_name : list of str, or 'auto', optional (default="auto")
592
593
        Feature names.
        If 'auto' and data is pandas DataFrame, data columns names are used.
594
    categorical_feature : list of str or int, or 'auto', optional (default="auto")
595
596
        Categorical features.
        If list of int, interpreted as indices.
597
        If list of str, interpreted as feature names (need to specify ``feature_name`` as well).
598
        If 'auto' and data is pandas DataFrame, pandas unordered categorical columns are used.
599
        All values in categorical features will be cast to int32 and thus should be less than int32 max value (2147483647).
600
        Large values could be memory consuming. Consider using consecutive integers starting from zero.
601
        All negative values in categorical features will be treated as missing values.
602
        The output cannot be monotonically constrained with respect to a categorical feature.
603
        Floating point numbers in categorical features will be rounded towards 0.
604
605
    fpreproc : callable or None, optional (default=None)
        Preprocessing function that takes (dtrain, dtest, params)
wxchan's avatar
wxchan committed
606
        and returns transformed versions of those.
607
    seed : int, optional (default=0)
wxchan's avatar
wxchan committed
608
        Seed used to generate the folds (passed to numpy.random.seed).
609
    callbacks : list of callable, or None, optional (default=None)
610
        List of callback functions that are applied at each iteration.
611
        See Callbacks in Python API for more information.
612
613
614
    eval_train_metric : bool, optional (default=False)
        Whether to display the train metric in progress.
        The score of the metric is calculated again after each training step, so there is some impact on performance.
615
616
    return_cvbooster : bool, optional (default=False)
        Whether to return Booster models trained on each fold through ``CVBooster``.
wxchan's avatar
wxchan committed
617

618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
    Note
    ----
    A custom objective function can be provided for the ``objective`` parameter.
    It should accept two parameters: preds, train_data and return (grad, hess).

        preds : numpy 1-D array or numpy 2-D array (for multi-class task)
            The predicted values.
            Predicted values are returned before any transformation,
            e.g. they are raw margin instead of probability of positive class for binary task.
        train_data : Dataset
            The training dataset.
        grad : numpy 1-D array or numpy 2-D array (for multi-class task)
            The value of the first order derivative (gradient) of the loss
            with respect to the elements of preds for each sample point.
        hess : numpy 1-D array or numpy 2-D array (for multi-class task)
            The value of the second order derivative (Hessian) of the loss
            with respect to the elements of preds for each sample point.

    For multi-class task, preds are numpy 2-D array of shape = [n_samples, n_classes],
    and grad and hess should be returned in the same format.

wxchan's avatar
wxchan committed
639
640
    Returns
    -------
641
642
643
644
    eval_hist : dict
        Evaluation history.
        The dictionary has the following format:
        {'metric1-mean': [values], 'metric1-stdv': [values],
Qiwei Ye's avatar
Qiwei Ye committed
645
        'metric2-mean': [values], 'metric2-stdv': [values],
646
        ...}.
647
        If ``return_cvbooster=True``, also returns trained boosters via ``cvbooster`` key.
wxchan's avatar
wxchan committed
648
    """
Guolin Ke's avatar
Guolin Ke committed
649
    if not isinstance(train_set, Dataset):
650
        raise TypeError("Training only accepts Dataset object")
651
    params = copy.deepcopy(params)
652
653
654
655
656
    params = _choose_param_value(
        main_param_name='objective',
        params=params,
        default_value=None
    )
657
    fobj: Optional[_LGBM_CustomObjectiveFunction] = None
658
659
660
    if callable(params["objective"]):
        fobj = params["objective"]
        params["objective"] = 'none'
661
    for alias in _ConfigAliases.get("num_iterations"):
662
        if alias in params:
663
            _log_warning(f"Found '{alias}' in params. Will use it instead of 'num_boost_round' argument")
664
            num_boost_round = params.pop(alias)
665
    params["num_iterations"] = num_boost_round
666
667
668
669
670
671
672
673
    # setting early stopping via global params should be possible
    params = _choose_param_value(
        main_param_name="early_stopping_round",
        params=params,
        default_value=None
    )
    if params["early_stopping_round"] is None:
        params.pop("early_stopping_round")
674
    first_metric_only = params.get('first_metric_only', False)
675

676
677
    if num_boost_round <= 0:
        raise ValueError("num_boost_round should be greater than zero.")
678
    if isinstance(init_model, (str, Path)):
679
        predictor = _InnerPredictor(model_file=init_model, pred_parameter=params)
Guolin Ke's avatar
Guolin Ke committed
680
    elif isinstance(init_model, Booster):
681
        predictor = init_model._to_predictor(dict(init_model.params, **params))
Guolin Ke's avatar
Guolin Ke committed
682
683
684
    else:
        predictor = None

Peter's avatar
Peter committed
685
    if metrics is not None:
686
687
        for metric_alias in _ConfigAliases.get("metric"):
            params.pop(metric_alias, None)
Peter's avatar
Peter committed
688
        params['metric'] = metrics
wxchan's avatar
wxchan committed
689

690
691
692
693
694
    train_set._update_params(params) \
             ._set_predictor(predictor) \
             .set_feature_name(feature_name) \
             .set_categorical_feature(categorical_feature)

wxchan's avatar
wxchan committed
695
    results = collections.defaultdict(list)
696
    cvfolds = _make_n_folds(full_data=train_set, folds=folds, nfold=nfold,
697
                            params=params, seed=seed, fpreproc=fpreproc,
698
699
                            stratified=stratified, shuffle=shuffle,
                            eval_train_metric=eval_train_metric)
wxchan's avatar
wxchan committed
700
701

    # setup callbacks
702
    if callbacks is None:
703
        callbacks_set = set()
wxchan's avatar
wxchan committed
704
705
706
    else:
        for i, cb in enumerate(callbacks):
            cb.__dict__.setdefault('order', i - len(callbacks))
707
        callbacks_set = set(callbacks)
708
709

    if "early_stopping_round" in params:
710
        callbacks_set.add(
711
            callback.early_stopping(
712
                stopping_rounds=params["early_stopping_round"],  # type: ignore[arg-type]
713
714
715
716
717
718
719
720
                first_metric_only=first_metric_only,
                verbose=_choose_param_value(
                    main_param_name="verbosity",
                    params=params,
                    default_value=1
                ).pop("verbosity") > 0
            )
        )
wxchan's avatar
wxchan committed
721

722
723
724
725
    callbacks_before_iter_set = {cb for cb in callbacks_set if getattr(cb, 'before_iteration', False)}
    callbacks_after_iter_set = callbacks_set - callbacks_before_iter_set
    callbacks_before_iter = sorted(callbacks_before_iter_set, key=attrgetter('order'))
    callbacks_after_iter = sorted(callbacks_after_iter_set, key=attrgetter('order'))
wxchan's avatar
wxchan committed
726

727
    for i in range(num_boost_round):
wxchan's avatar
wxchan committed
728
        for cb in callbacks_before_iter:
729
730
            cb(callback.CallbackEnv(model=cvfolds,
                                    params=params,
wxchan's avatar
wxchan committed
731
732
733
734
                                    iteration=i,
                                    begin_iteration=0,
                                    end_iteration=num_boost_round,
                                    evaluation_result_list=None))
wxchan's avatar
wxchan committed
735
        cvfolds.update(fobj=fobj)
736
        res = _agg_cv_result(cvfolds.eval_valid(feval))
wxchan's avatar
wxchan committed
737
        for _, key, mean, _, std in res:
738
739
            results[f'{key}-mean'].append(mean)
            results[f'{key}-stdv'].append(std)
wxchan's avatar
wxchan committed
740
741
        try:
            for cb in callbacks_after_iter:
742
743
                cb(callback.CallbackEnv(model=cvfolds,
                                        params=params,
wxchan's avatar
wxchan committed
744
745
746
747
                                        iteration=i,
                                        begin_iteration=0,
                                        end_iteration=num_boost_round,
                                        evaluation_result_list=res))
748
749
        except callback.EarlyStopException as earlyStopException:
            cvfolds.best_iteration = earlyStopException.best_iteration + 1
750
751
            for bst in cvfolds.boosters:
                bst.best_iteration = cvfolds.best_iteration
wxchan's avatar
wxchan committed
752
            for k in results:
753
                results[k] = results[k][:cvfolds.best_iteration]
wxchan's avatar
wxchan committed
754
            break
755
756
757
758

    if return_cvbooster:
        results['cvbooster'] = cvfolds

wxchan's avatar
wxchan committed
759
    return dict(results)