8.3. Cross-Validation¶

Cross-validation is a step where we take our training sample and further divide it in many folds, as in the illustration here:

As we talked about in the last chapter, cross-validation allows us to test our models outside the training data more often. This trick reduces the likelihood of overfitting and improves generalization: It should improve our model’s performance when we apply it outside the training data.

Warning

I say “it should improve our model’s performance” because the exact manner in which you create the folds matters!

See the tip below.

8.3.1. Basic example¶

Like before, let’s first load the data. Notice I consolidated the import lines at the top.

import pandas as pd
import numpy as np
from sklearn.linear_model import Ridge
from sklearn.model_selection import train_test_split

url        = 'https://github.com/LeDataSciFi/data/blob/main/Fannie%20Mae/Fannie_Mae_Plus_Data.gzip?raw=true'
fannie_mae = pd.read_csv(url,compression='gzip').dropna()
y          = fannie_mae.Original_Interest_Rate
fannie_mae = (fannie_mae
                  .assign(l_credscore = np.log(fannie_mae['Borrower_Credit_Score_at_Origination']),
                          l_LTV = np.log(fannie_mae['Original_LTV_(OLTV)']),
                         )
              .iloc[:,-11:] # limit to these vars for the sake of this example
             )

And, like before, we then split off some of the data into a testing sample.

For the sake of simplicity (laziness?), let’s just reuse the train_test_split approach from the last page.

rng = np.random.RandomState(0) # this helps us control the randomness so we can reproduce results exactly
X_train, X_test, y_train, y_test = train_test_split(fannie_mae, y, random_state=rng)

8.3.2. Set up the CV¶

Sk-learn makes cross-validation pretty easy. We use the cross_validate("estimator",X_train,y_train,cv,scoring,...) function (documentation here) which, under the hood, will

Create folds in X_train and y_train using whatever method you put in the cv parameter. For each fold, it will create a smaller “training partition” and “validation partition” like in the figure at the top of this page.
For each fold, it will
1. Fit your “estimator” on the smaller training partition it creates for that fold (as if you ran estimator.fit(X_trainingpartition,y_trainingpartition)).
2. Use that fitted estimator on the validation partition (as if you ran estimator.predict(X_validationpartition)).
3. Score those predictions with the function(s) you put in scoring.
Output a dictionary object with performance data for each fold.

Important

So, to use cross_validate(), you need to decide on and set up:

Your preferred folding method (and number of folds)
Your estimator (or pipeline ending in an estimator)
Your scoring method(s)

The code can be this simple:

from sklearn.model_selection import KFold, cross_validate

cv    = KFold(5)                       # pick and set up fold method
ridge = Ridge(alpha=1.0)               # set up model/estimator
cross_validate(ridge,
               X_train,y_train, cv=cv, 
               scoring='r2')           # tell it the scoring method here

{'fit_time': array([0.0181005, 0.       , 0.       , 0.       , 0.       ]),
 'score_time': array([0.        , 0.01563931, 0.        , 0.        , 0.        ]),
 'test_score': array([0.90789446, 0.89926394, 0.900032  , 0.90479828, 0.90327986])}

Note

Wow, that was easy! Just 3 lines of code (and an import).

And we can output test score statistics like:

scores = cross_validate(ridge, X_train, y_train, cv=cv, scoring="r2")
print(scores["test_score"].mean())  # scores is just a dictionary
print(scores["test_score"].std())

0.9030537085469961
0.0031629307869794876

8.3.3. Choosing what kind of CV folds to use¶

What should we put in the cv = ? line of code?

It depends on the dataset:

IID data: If we have a dataset with one observation per unit and all observations are at either the same time, or if time can be ignored:
- KFold() and ShuffleSplit()
- If you have a classification task with imbalanced labels, use StratifiedKFold() and StratifiedShuffleSplit()
Grouped, time-independent data: If time can be ignored or there is only one time period, and you have multiple observations for each unit (“groups”), your goal is likely to find out if a model trained on a particular set of groups generalizes well to the unseen groups:
- GroupKFold() and GroupShuffleSplit
- If you have a classification task with imbalanced labels, use StratifiedGroupKFold()
If your data and/or task is time dependent: E.g. predicting stock returns, any setting where the choice depends on prior choices and outcomes
- You must ensure that the validation partitions are subsequent to the training sample.
- Rarely: If you have a simple time series dataset (one observation for each time), use the built-in TimeSeriesSplit()
- Usually: If you have a cross-sectional panel (multiple observations for each time), build a custom splitter to generate your folds.

Tip

This page should be your first reference to learn about the CV splitting functions listed above.

8.3.4. Custom CV folds¶

You can explicitly design and create customer CV folds to suit your problem. The cross_validation() documentation says that cv can be “An iterable yielding (train, test) splits as arrays of indices.”

Let’s use this example:

cv_custom = [([0,1],[2]),
             ([0,1,2],[3]),
             ([0,1,2,3],[4])]

cross_validate(ridge,
               X_train,y_train, cv=cv_custom, 
               scoring='r2')  

cv_custom is a list (lists are an “iterable” object) with 3 elements, so our cross validation will have 3 folds.

The first fold is given by the first element: ([0,1],[2]), which says the training data is rows 0 and 1, and the validation is done on row 2.
In the second fold, train on rows 0 to 2, and validate on row 3.
And so on.

8.3.5. Code for rolling OOS testing (v0)¶

Important

The code below is almost plug-and-play! (But not quite!)

One procedure to do rolling OOS testing was introduced on this page, and I copied it here in the sidebar. It’s a common choice that works well in many settings. It works when you have many firms or units (whether each unit has one or multiple observations per year), or even with a single time series!1 And it can be adjusted to other units of time (monthly, weekly, decades), or only every few units of time.

The code below implements it and can be used with appropriate adjustments for your setting.

# adjust the inside of "groupby()" to your df/problem, pick other parameters

time_groups               = X_train.groupby(X_train['DATE'].dt.year).groups 
min_periods_in_train      = 5
training_expanding_window = True

# shouldn't need to adjust this code: 

sorted_groups = [list(value) for (key, value) in sorted(time_groups.items())]

if training_expanding_window:

    cv = [([i for g in sorted_groups[:y] for i in g],sorted_groups[y]) 
            for y in range(min_periods_in_train , len(sorted_groups))]

else:
    
    cv = [([i for g in sorted_groups[y-min_periods_in_train:y] for i in g],sorted_groups[y]) 
            for y in range(min_periods_in_train, len(sorted_groups))]

Tip

Extra credit: Convert the code above into a function for the community codebook!

Something like:

def rolling_oos_cv(???): # you need to decide on arguments
    ??? 
    return cv

Considerations/bonus:

ESSENTIAL: How should the user specify the time dimensions to groupby? What if they want to use months, weeks, etc. instead of years?
EASY BONUS: Can the user ask for multiple time periods in the validation sets? E.g. predict the next two years?
HARDER BONUS: Can the user ask to skip some folds? E.g. if they group the data by months, but only do the training and prediction for the first month each year?

8.3.6. Code for rolling OOS testing (v1)¶

The code above works. It lacks some features, and until a classmate codes it up into a nice function, it requires copy-pasting all of the code I wrote, and adjusting it.

As of mid-2022, someone has finally made a function that looks like a promising solution. Here is the documentation for GroupTimeSeriesSplit. However, it’s new and has some quirks.

Here is an illustration of how it divides up the sample. First, I’ll create a simple dataset we can look at. Notice we have several firms in many years.

import pandas as pd

df = pd.DataFrame({'year':[2000,2000,2000,2001,2001,2002,2002,2002,2002,2003,2004,2004,2006],
                   'firm':[1,2,3,1,2,1,2,3,4,4,4,5,5],
                   'X':   [0,4,5,2,5,7,2,4,4,9,8,9,8],
                   'y':   [0,0,1,1,1,1,0,0,1,1,0,1,0]
                  })
display(df.T)

	0	1	2	3	4	5	6	7	8	9	10	11	12
year	2000	2000	2000	2001	2001	2002	2002	2002	2002	2003	2004	2004	2006
firm	1	2	3	1	2	1	2	3	4	4	4	5	5
X	0	4	5	2	5	7	2	4	4	9	8	9	8
y	0	0	1	1	1	1	0	0	1	1	0	1	0

GroupTimeSeriesSplit() correctly splits up the sample:

from mlxtend.evaluate.time_series import GroupTimeSeriesSplit, plot_splits
cv_args = {'test_size':1, 'n_splits':5,'window_type':'expanding'}
plot_splits(df.X, df.y, df.year, **cv_args)

Using it is easy:

Replace the cv= with GroupTimeSeriesSplit() and the parameters you want.
Add groups= to cross_validate, and it should be the variable containing the time info.

from sklearn.dummy import DummyClassifier
from sklearn.model_selection import cross_validate
from mlxtend.evaluate import GroupTimeSeriesSplit

cv      = GroupTimeSeriesSplit(test_size=1, 
                               n_splits=5, 
                               window_type='expanding') # set up fold method
clf     = DummyClassifier(strategy="most_frequent")     # set up model/estimator

cross_validate(clf,
               df.X, df.y,
               cv=cv,
               groups=df.year, 
               scoring="accuracy")["test_score"]        # for this page, just print results

array([0. , 0.5, 1. , 0.5, 0. ])

8.3.7. Next step: Pipelines¶

The model above

Only uses a few continuous variables: what if we want to include other variable types (like categorical)?
Uses the variables as given: ML algorithms often need you to transform your variables
Doesn’t deal with any data problems (e.g. missing values or outliers)
Doesn’t create any interaction terms or polynomial transformations
Uses every variable I give it: But if your input data had 400 variables, you’d be in danger of overfitting!

At this point, you are capable of solving all of these problems. (For example, you could clean the data in pandas.)

But for our models to be robust to evil monsters like “data leakage”, we need the fixes to be done within pipelines.

1: You could do TimeSeriesSplit(), but if you have 20 years of daily trading data, there are potentially ~500 possible splits! That will be slow when you evaluate a bunch of models a bunch of times! The procedure above reduces that greatly.

LeDataSciFi-2024