engine.py 32.9 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
                    _LGBM_CategoricalFeatureConfiguration, _LGBM_CustomObjectiveFunction,
                    _LGBM_FeatureNameConfiguration, _log_warning)
16
from .compat import SKLEARN_INSTALLED, _LGBMBaseCrossValidator, _LGBMGroupKFold, _LGBMStratifiedKFold
wxchan's avatar
wxchan committed
17

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


25
_LGBM_CustomMetricFunction = Callable[
26
    [np.ndarray, Dataset],
27
    Union[Tuple[str, float, bool], List[Tuple[str, float, bool]]]
28
]
wxchan's avatar
wxchan committed
29

30
31
32
33
34
_LGBM_PreprocFunction = Callable[
    [Dataset, Dataset, Dict[str, Any]],
    Tuple[Dataset, Dataset, Dict[str, Any]]
]

35
36
37
38
39
40
41
42
43

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,
44
45
    feature_name: _LGBM_FeatureNameConfiguration = 'auto',
    categorical_feature: _LGBM_CategoricalFeatureConfiguration = 'auto',
46
47
48
    keep_training_booster: bool = False,
    callbacks: Optional[List[Callable]] = None
) -> Booster:
49
    """Perform the training with given parameters.
wxchan's avatar
wxchan committed
50
51
52
53

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

69
            preds : numpy 1-D array or numpy 2-D array (for multi-class task)
70
                The predicted values.
71
                For multi-class task, preds are numpy 2-D array of shape = [n_samples, n_classes].
72
                If custom objective function is used, predicted values are returned before any transformation,
73
                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
74
            eval_data : Dataset
75
                A ``Dataset`` to evaluate.
76
            eval_name : str
77
                The name of evaluation function (without whitespaces).
78
79
80
81
82
            eval_result : float
                The eval result.
            is_higher_better : bool
                Is eval result higher better, e.g. AUC is ``is_higher_better``.

83
84
        To ignore the default metric corresponding to the used objective,
        set the ``metric`` parameter to the string ``"None"`` in ``params``.
85
    init_model : str, pathlib.Path, Booster or None, optional (default=None)
86
        Filename of LightGBM model or Booster instance used for continue training.
87
    feature_name : list of str, or 'auto', optional (default="auto")
88
89
        Feature names.
        If 'auto' and data is pandas DataFrame, data columns names are used.
90
    categorical_feature : list of str or int, or 'auto', optional (default="auto")
91
92
        Categorical features.
        If list of int, interpreted as indices.
93
        If list of str, interpreted as feature names (need to specify ``feature_name`` as well).
94
        If 'auto' and data is pandas DataFrame, pandas unordered categorical columns are used.
95
        All values in categorical features will be cast to int32 and thus should be less than int32 max value (2147483647).
96
        Large values could be memory consuming. Consider using consecutive integers starting from zero.
97
        All negative values in categorical features will be treated as missing values.
98
        The output cannot be monotonically constrained with respect to a categorical feature.
99
        Floating point numbers in categorical features will be rounded towards 0.
100
101
102
    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.
103
        This means you won't be able to use ``eval``, ``eval_train`` or ``eval_valid`` methods of the returned Booster.
104
105
        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``.
106
        You can still use _InnerPredictor as ``init_model`` for future continue training.
107
    callbacks : list of callable, or None, optional (default=None)
108
        List of callback functions that are applied at each iteration.
109
        See Callbacks in Python API for more information.
wxchan's avatar
wxchan committed
110

111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
    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
132
133
    Returns
    -------
134
135
    booster : Booster
        The trained Booster model.
wxchan's avatar
wxchan committed
136
    """
137
    # create predictor first
138
    params = copy.deepcopy(params)
139
140
141
142
143
    params = _choose_param_value(
        main_param_name='objective',
        params=params,
        default_value=None
    )
144
    fobj: Optional[_LGBM_CustomObjectiveFunction] = None
145
146
147
    if callable(params["objective"]):
        fobj = params["objective"]
        params["objective"] = 'none'
148
    for alias in _ConfigAliases.get("num_iterations"):
149
        if alias in params:
150
            num_boost_round = params.pop(alias)
151
            _log_warning(f"Found `{alias}` in params. Will use it instead of argument")
152
    params["num_iterations"] = num_boost_round
153
154
155
156
157
158
159
160
    # 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")
161
    first_metric_only = params.get('first_metric_only', False)
162

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

175
176
177
178
    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
179

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

211
212
213
214
215
216
217
218
219
220
221
222
    if "early_stopping_round" in params:
        callbacks_set.add(
            callback.early_stopping(
                stopping_rounds=params["early_stopping_round"],
                first_metric_only=first_metric_only,
                verbose=_choose_param_value(
                    main_param_name="verbosity",
                    params=params,
                    default_value=1
                ).pop("verbosity") > 0
            )
        )
223

224
225
226
227
    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
228

229
    # construct booster
230
231
232
233
    try:
        booster = Booster(params=params, train_set=train_set)
        if is_valid_contain_train:
            booster.set_train_data_name(train_data_name)
234
        for valid_set, name_valid_set in zip(reduced_valid_sets, name_valid_sets):
235
236
237
238
239
            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()
240
    booster.best_iteration = 0
wxchan's avatar
wxchan committed
241

242
    # start training
243
    for i in range(init_iteration, init_iteration + num_boost_round):
wxchan's avatar
wxchan committed
244
245
        for cb in callbacks_before_iter:
            cb(callback.CallbackEnv(model=booster,
246
                                    params=params,
wxchan's avatar
wxchan committed
247
                                    iteration=i,
248
249
                                    begin_iteration=init_iteration,
                                    end_iteration=init_iteration + num_boost_round,
wxchan's avatar
wxchan committed
250
251
252
253
254
255
                                    evaluation_result_list=None))

        booster.update(fobj=fobj)

        evaluation_result_list = []
        # check evaluation result.
256
        if valid_sets is not None:
wxchan's avatar
wxchan committed
257
258
259
260
261
262
            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,
263
                                        params=params,
wxchan's avatar
wxchan committed
264
                                        iteration=i,
265
266
                                        begin_iteration=init_iteration,
                                        end_iteration=init_iteration + num_boost_round,
wxchan's avatar
wxchan committed
267
                                        evaluation_result_list=evaluation_result_list))
268
269
        except callback.EarlyStopException as earlyStopException:
            booster.best_iteration = earlyStopException.best_iteration + 1
wxchan's avatar
wxchan committed
270
            evaluation_result_list = earlyStopException.best_score
wxchan's avatar
wxchan committed
271
            break
272
    booster.best_score = collections.defaultdict(collections.OrderedDict)
wxchan's avatar
wxchan committed
273
274
    for dataset_name, eval_name, score, _ in evaluation_result_list:
        booster.best_score[dataset_name][eval_name] = score
275
    if not keep_training_booster:
276
        booster.model_from_string(booster.model_to_string()).free_dataset()
wxchan's avatar
wxchan committed
277
278
279
    return booster


280
class CVBooster:
281
282
    """CVBooster in LightGBM.

283
    Auxiliary data structure to hold and redirect all boosters of ``cv()`` function.
284
    This class has the same methods as Booster class.
285
286
287
288
289
290
    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()``
291
292
293
294
295
296
297
298

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

300
301
302
303
    def __init__(
        self,
        model_file: Optional[Union[str, Path]] = None
    ):
304
305
        """Initialize the CVBooster.

306
307
308
309
        Parameters
        ----------
        model_file : str, pathlib.Path or None, optional (default=None)
            Path to the CVBooster model file.
310
        """
311
        self.boosters: List[Booster] = []
312
        self.best_iteration = -1
313

314
315
316
317
        if model_file is not None:
            with open(model_file, "r") as file:
                self._from_dict(json.load(file))

318
    def _append(self, booster: Booster) -> None:
319
        """Add a booster to CVBooster."""
320
321
        self.boosters.append(booster)

322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
    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}

337
    def __getattr__(self, name: str) -> Callable[[Any, Any], List[Any]]:
338
        """Redirect methods call of CVBooster."""
339
        def handler_function(*args: Any, **kwargs: Any) -> List[Any]:
340
            """Call methods with each booster, and concatenate their results."""
341
342
343
344
            ret = []
            for booster in self.boosters:
                ret.append(getattr(booster, name)(*args, **kwargs))
            return ret
345
        return handler_function
wxchan's avatar
wxchan committed
346

347
348
349
350
351
352
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
    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

431

432
433
434
435
436
437
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,
438
439
440
441
    fpreproc: Optional[_LGBM_PreprocFunction],
    stratified: bool,
    shuffle: bool,
    eval_train_metric: bool
442
) -> CVBooster:
443
    """Make a n-fold list of Booster from random indices."""
wxchan's avatar
wxchan committed
444
445
    full_data = full_data.construct()
    num_data = full_data.num_data()
446
    if folds is not None:
447
448
449
450
451
452
        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:
453
                group_info = np.array(group_info, dtype=np.int32, copy=False)
454
                flatted_group = np.repeat(range(len(group_info)), repeats=group_info)
455
            else:
456
                flatted_group = np.zeros(num_data, dtype=np.int32)
457
            folds = folds.split(X=np.empty(num_data), y=full_data.get_label(), groups=flatted_group)
wxchan's avatar
wxchan committed
458
    else:
459
460
461
        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
462
            if not SKLEARN_INSTALLED:
463
                raise LightGBMError('scikit-learn is required for ranking cv')
464
            # ranking task, split according to groups
465
            group_info = np.array(full_data.get_group(), dtype=np.int32, copy=False)
466
            flatted_group = np.repeat(range(len(group_info)), repeats=group_info)
467
            group_kfold = _LGBMGroupKFold(n_splits=nfold)
468
            folds = group_kfold.split(X=np.empty(num_data), groups=flatted_group)
wxchan's avatar
wxchan committed
469
470
        elif stratified:
            if not SKLEARN_INSTALLED:
471
                raise LightGBMError('scikit-learn is required for stratified cv')
472
            skf = _LGBMStratifiedKFold(n_splits=nfold, shuffle=shuffle, random_state=seed)
473
            folds = skf.split(X=np.empty(num_data), y=full_data.get_label())
extremin's avatar
extremin committed
474
        else:
wxchan's avatar
wxchan committed
475
476
477
478
479
            if shuffle:
                randidx = np.random.RandomState(seed).permutation(num_data)
            else:
                randidx = np.arange(num_data)
            kstep = int(num_data / nfold)
480
481
482
            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
483

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

wxchan's avatar
wxchan committed
500

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

wxchan's avatar
wxchan committed
515

516
517
518
519
520
521
522
523
524
525
526
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,
527
528
    feature_name: _LGBM_FeatureNameConfiguration = 'auto',
    categorical_feature: _LGBM_CategoricalFeatureConfiguration = 'auto',
529
530
531
532
533
534
    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
535
    """Perform the cross-validation with given parameters.
wxchan's avatar
wxchan committed
536
537
538
539

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

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

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

611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
    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
632
633
    Returns
    -------
634
635
636
637
    eval_hist : dict
        Evaluation history.
        The dictionary has the following format:
        {'metric1-mean': [values], 'metric1-stdv': [values],
Qiwei Ye's avatar
Qiwei Ye committed
638
        'metric2-mean': [values], 'metric2-stdv': [values],
639
        ...}.
640
        If ``return_cvbooster=True``, also returns trained boosters via ``cvbooster`` key.
wxchan's avatar
wxchan committed
641
    """
Guolin Ke's avatar
Guolin Ke committed
642
    if not isinstance(train_set, Dataset):
643
        raise TypeError("Training only accepts Dataset object")
644
    params = copy.deepcopy(params)
645
646
647
648
649
    params = _choose_param_value(
        main_param_name='objective',
        params=params,
        default_value=None
    )
650
    fobj: Optional[_LGBM_CustomObjectiveFunction] = None
651
652
653
    if callable(params["objective"]):
        fobj = params["objective"]
        params["objective"] = 'none'
654
    for alias in _ConfigAliases.get("num_iterations"):
655
        if alias in params:
656
            _log_warning(f"Found '{alias}' in params. Will use it instead of 'num_boost_round' argument")
657
            num_boost_round = params.pop(alias)
658
    params["num_iterations"] = num_boost_round
659
660
661
662
663
664
665
666
    # 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")
667
    first_metric_only = params.get('first_metric_only', False)
668

669
670
    if num_boost_round <= 0:
        raise ValueError("num_boost_round should be greater than zero.")
671
    if isinstance(init_model, (str, Path)):
672
        predictor = _InnerPredictor(model_file=init_model, pred_parameter=params)
Guolin Ke's avatar
Guolin Ke committed
673
    elif isinstance(init_model, Booster):
674
        predictor = init_model._to_predictor(dict(init_model.params, **params))
Guolin Ke's avatar
Guolin Ke committed
675
676
677
    else:
        predictor = None

Peter's avatar
Peter committed
678
    if metrics is not None:
679
680
        for metric_alias in _ConfigAliases.get("metric"):
            params.pop(metric_alias, None)
Peter's avatar
Peter committed
681
        params['metric'] = metrics
wxchan's avatar
wxchan committed
682

683
684
685
686
687
    train_set._update_params(params) \
             ._set_predictor(predictor) \
             .set_feature_name(feature_name) \
             .set_categorical_feature(categorical_feature)

wxchan's avatar
wxchan committed
688
    results = collections.defaultdict(list)
689
    cvfolds = _make_n_folds(full_data=train_set, folds=folds, nfold=nfold,
690
                            params=params, seed=seed, fpreproc=fpreproc,
691
692
                            stratified=stratified, shuffle=shuffle,
                            eval_train_metric=eval_train_metric)
wxchan's avatar
wxchan committed
693
694

    # setup callbacks
695
    if callbacks is None:
696
        callbacks_set = set()
wxchan's avatar
wxchan committed
697
698
699
    else:
        for i, cb in enumerate(callbacks):
            cb.__dict__.setdefault('order', i - len(callbacks))
700
        callbacks_set = set(callbacks)
701
702

    if "early_stopping_round" in params:
703
        callbacks_set.add(
704
705
706
707
708
709
710
711
712
713
            callback.early_stopping(
                stopping_rounds=params["early_stopping_round"],
                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
714

715
716
717
718
    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
719

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

    if return_cvbooster:
        results['cvbooster'] = cvfolds

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