{"metadata":{"kernelspec":{"language":"python","display_name":"Python 3","name":"python3"},"language_info":{"name":"python","version":"3.10.14","mimetype":"text/x-python","codemirror_mode":{"name":"ipython","version":3},"pygments_lexer":"ipython3","nbconvert_exporter":"python","file_extension":".py"},"kaggle":{"accelerator":"none","dataSources":[{"sourceId":81933,"databundleVersionId":9643020,"sourceType":"competition"}],"dockerImageVersionId":30786,"isInternetEnabled":false,"language":"python","sourceType":"notebook","isGpuEnabled":false}},"nbformat_minor":4,"nbformat":4,"cells":[{"cell_type":"code","source":"# Import libraries\nimport numpy as np\nimport pandas as pd\nimport os\nimport re\nfrom sklearn.base import clone\nfrom sklearn.metrics import cohen_kappa_score\nfrom sklearn.model_selection import StratifiedKFold\nfrom scipy.optimize import minimize\nfrom concurrent.futures import ThreadPoolExecutor\nfrom tqdm import tqdm\n\nfrom sklearn.preprocessing import MinMaxScaler, StandardScaler, RobustScaler\nfrom sklearn.decomposition import PCA\nfrom sklearn.model_selection import train_test_split\nfrom keras.models import Model\nfrom keras.layers import Input, Dense\nfrom keras.optimizers import Adam\nimport torch\nimport torch.nn as nn\nimport torch.optim as optim\nfrom torch.utils.data import DataLoader, TensorDataset\n\nfrom colorama import Fore, Style\nfrom IPython.display import clear_output\nimport warnings\nfrom lightgbm import LGBMRegressor\nfrom xgboost import XGBRegressor\nfrom catboost import CatBoostRegressor\nfrom sklearn.ensemble import VotingRegressor, RandomForestRegressor, GradientBoostingRegressor\nfrom sklearn.impute import SimpleImputer, KNNImputer\nfrom sklearn.pipeline import Pipeline\nwarnings.filterwarnings('ignore')\npd.options.display.max_columns = None\n\nSEED = 42\nn_splits = 5\n\nimport optuna\nimport warnings\nimport tensorflow as tf\nimport time\nfrom sklearn import preprocessing\nfrom sklearn.model_selection import train_test_split, StratifiedKFold\nfrom sklearn.metrics import mean_squared_error\nfrom concurrent.futures import ThreadPoolExecutor\nfrom statsmodels.stats.outliers_influence import variance_inflation_factor\nfrom sklearn.ensemble import StackingRegressor\nfrom sklearn.neural_network import MLPRegressor\nfrom sklearn.base import BaseEstimator, RegressorMixin\nfrom sklearn.linear_model import ElasticNet\nfrom sklearn.ensemble import HistGradientBoostingRegressor\nfrom sklearn.manifold import TSNE\nfrom sklearn.linear_model import Ridge\nfrom joblib import Parallel, delayed\nfrom sklearn.cluster import DBSCAN\nimport polars as pl\nimport polars.selectors as cs\n\nfrom scipy.optimize import minimize\nfrom sklearn.metrics import cohen_kappa_score\nfrom sklearn.linear_model import Ridge\nfrom sklearn.model_selection import KFold\nfrom sklearn.ensemble import StackingRegressor\nfrom torch import nn, optim\nfrom sklearn.base import BaseEstimator, RegressorMixin\n\nimport matplotlib.pyplot as plt\nimport seaborn as sns\nfrom sklearn.cluster import DBSCAN\nfrom sklearn.manifold import TSNE\nfrom mpl_toolkits.mplot3d import Axes3D","metadata":{"_uuid":"8f2839f25d086af736a60e9eeb907d3b93b6e0e5","_cell_guid":"b1076dfc-b9ad-4769-8c92-a6c4dae69d19","trusted":true,"execution":{"iopub.status.busy":"2024-12-01T02:13:55.577026Z","iopub.execute_input":"2024-12-01T02:13:55.577521Z","iopub.status.idle":"2024-12-01T02:13:56.494570Z","shell.execute_reply.started":"2024-12-01T02:13:55.577461Z","shell.execute_reply":"2024-12-01T02:13:56.493011Z"}},"outputs":[],"execution_count":null},{"cell_type":"code","source":"def process_file(filename, dirname):\n    df = pd.read_parquet(os.path.join(dirname, filename, 'part-0.parquet'))\n    df.drop('step', axis=1, inplace=True)\n    return df.describe().values.reshape(-1), filename.split('=')[1]\n\ndef load_time_series(dirname) -> pd.DataFrame:\n    ids = os.listdir(dirname)\n    \n    with ThreadPoolExecutor() as executor:\n        results = list(tqdm(executor.map(lambda fname: process_file(fname, dirname), ids), total=len(ids)))\n    \n    stats, indexes = zip(*results)\n    \n    df = pd.DataFrame(stats, columns=[f\"stat_{i}\" for i in range(len(stats[0]))])\n    df['id'] = indexes\n    return df","metadata":{"trusted":true,"execution":{"iopub.status.busy":"2024-12-01T02:13:56.496711Z","iopub.execute_input":"2024-12-01T02:13:56.497371Z","iopub.status.idle":"2024-12-01T02:13:56.505612Z","shell.execute_reply.started":"2024-12-01T02:13:56.497325Z","shell.execute_reply":"2024-12-01T02:13:56.504344Z"}},"outputs":[],"execution_count":null},{"cell_type":"code","source":"# Sparse Autoencoder Model\nclass SparseAutoencoder(nn.Module):\n    def __init__(self, input_dim, sparsity_weight=1e-5):\n        super(SparseAutoencoder, self).__init__()\n        self.sparsity_weight = sparsity_weight\n        self.encoder = nn.Sequential(\n            nn.Linear(input_dim, 64),\n            nn.ReLU(),\n            nn.Linear(64, 32),\n            nn.ReLU(),\n            nn.Linear(32, 16),\n            nn.ReLU()\n        )\n        \n        self.decoder = nn.Sequential(\n            nn.Linear(16, 32),\n            nn.ReLU(),\n            nn.Linear(32, 64),\n            nn.ReLU(),\n            nn.Linear(64, input_dim),\n            nn.Sigmoid()  # Outputs in the range [0, 1]\n        )\n        \n    def forward(self, x):\n        encoded = self.encoder(x)\n        decoded = self.decoder(encoded)\n        return encoded, decoded\n\n# Preparing Data\n# Option to use different scalers: MinMaxScaler, StandardScaler, RobustScaler\ndef prepare_data(data, scaler_type='MinMaxScaler'):\n    if scaler_type == 'StandardScaler':\n        scaler = StandardScaler()\n    elif scaler_type == 'RobustScaler':\n        scaler = RobustScaler()\n    else:\n        scaler = MinMaxScaler()\n    \n    data_scaled = scaler.fit_transform(data)\n    return torch.tensor(data_scaled, dtype=torch.float32), scaler\n\n# Apply PCA for Dimensionality Reduction\n# This can help focus the autoencoder on the most relevant features\ndef apply_pca(data, n_components=0.95):\n    pca = PCA(n_components=n_components)\n    data_pca = pca.fit_transform(data)\n    return data_pca, pca\n\n# Early Stopping Functionality\ndef early_stopping(patience):\n    class EarlyStopping:\n        def __init__(self, patience=patience):\n            self.patience = patience\n            self.counter = 0\n            self.best_loss = float('inf')\n            self.early_stop = False\n        \n        def __call__(self, loss):\n            if loss < self.best_loss:\n                self.best_loss = loss\n                self.counter = 0\n            else:\n                self.counter += 1\n                if self.counter >= self.patience:\n                    self.early_stop = True\n    return EarlyStopping()\n\n# Training the Sparse Autoencoder with DataFrame Output\ndef perform_autoencoder(data, epochs=100, batch_size=32, learning_rate=0.001, patience=10, scaler_type='MinMaxScaler', use_pca=False, sparsity_weight=1e-5):\n    # Preprocess Data\n    if use_pca:\n        data, pca = apply_pca(data)\n\n    data_tensor, scaler = prepare_data(data, scaler_type=scaler_type)\n    train_data, val_data = train_test_split(data_tensor, test_size=0.2, random_state=42)\n\n    train_loader = DataLoader(TensorDataset(train_data), batch_size=batch_size, shuffle=True)\n    val_loader = DataLoader(TensorDataset(val_data), batch_size=batch_size, shuffle=False)\n\n    model = SparseAutoencoder(input_dim=data.shape[1], sparsity_weight=sparsity_weight)\n    device = torch.device('cuda' if torch.cuda.is_available() else 'cpu')\n    model.to(device)\n\n    criterion = nn.SmoothL1Loss()  # Changed to Smooth L1 Loss\n    optimizer = optim.Adam(model.parameters(), lr=learning_rate)\n    stopper = early_stopping(patience=patience)\n\n    for epoch in range(epochs):\n        model.train()\n        train_loss = 0.0\n        for batch in train_loader:\n            batch = batch[0].to(device)\n            optimizer.zero_grad()\n            encoded, outputs = model(batch)\n            \n            # Reconstruction loss\n            loss = criterion(outputs, batch)\n            \n            # Sparsity penalty (L1 regularization on encoded activations)\n            l1_penalty = torch.mean(torch.abs(encoded))\n            loss += sparsity_weight * l1_penalty\n            \n            loss.backward()\n            optimizer.step()\n            train_loss += loss.item() * batch.size(0)\n\n        train_loss /= len(train_loader.dataset)\n\n        # Validation\n        model.eval()\n        val_loss = 0.0\n        with torch.no_grad():\n            for batch in val_loader:\n                batch = batch[0].to(device)\n                _, outputs = model(batch)\n                loss = criterion(outputs, batch)\n                val_loss += loss.item() * batch.size(0)\n\n        val_loss /= len(val_loader.dataset)\n        print(f\"Epoch {epoch+1}, Train Loss: {train_loss:.4f}, Validation Loss: {val_loss:.4f}\")\n\n        # Early stopping\n        stopper(val_loss)\n        if stopper.early_stop:\n            print(f\"Early stopping at epoch {epoch + 1}\")\n            break\n\n    # Convert tensor back to DataFrame for consistency\n    _, data_decoded = model(data_tensor.to(device))\n    data_decoded = data_decoded.cpu().detach().numpy()\n    df_encoded = pd.DataFrame(data_decoded, columns=[f'feature_{i}' for i in range(data_decoded.shape[1])])\n    return df_encoded","metadata":{"trusted":true,"execution":{"iopub.status.busy":"2024-12-01T02:13:56.507263Z","iopub.execute_input":"2024-12-01T02:13:56.507726Z","iopub.status.idle":"2024-12-01T02:13:56.529319Z","shell.execute_reply.started":"2024-12-01T02:13:56.507627Z","shell.execute_reply":"2024-12-01T02:13:56.528020Z"}},"outputs":[],"execution_count":null},{"cell_type":"code","source":"def feature_engineering(df):\n    season_cols = [col for col in df.columns if 'Season' in col]\n    df = df.drop(season_cols, axis=1) \n    df['BMI_Age'] = df['Physical-BMI'] * df['Basic_Demos-Age']\n    df['Internet_Hours_Age'] = df['PreInt_EduHx-computerinternet_hoursday'] * df['Basic_Demos-Age']\n    df['BMI_Internet_Hours'] = df['Physical-BMI'] * df['PreInt_EduHx-computerinternet_hoursday']\n    df['BFP_BMI'] = df['BIA-BIA_Fat'] / df['BIA-BIA_BMI']\n    df['FFMI_BFP'] = df['BIA-BIA_FFMI'] / df['BIA-BIA_Fat']\n    df['FMI_BFP'] = df['BIA-BIA_FMI'] / df['BIA-BIA_Fat']\n    df['LST_TBW'] = df['BIA-BIA_LST'] / df['BIA-BIA_TBW']\n    df['BFP_BMR'] = df['BIA-BIA_Fat'] * df['BIA-BIA_BMR']\n    df['BFP_DEE'] = df['BIA-BIA_Fat'] * df['BIA-BIA_DEE']\n    df['BMR_Weight'] = df['BIA-BIA_BMR'] / df['Physical-Weight']\n    df['DEE_Weight'] = df['BIA-BIA_DEE'] / df['Physical-Weight']\n    df['SMM_Height'] = df['BIA-BIA_SMM'] / df['Physical-Height']\n    df['Muscle_to_Fat'] = df['BIA-BIA_SMM'] / df['BIA-BIA_FMI']\n    df['Hydration_Status'] = df['BIA-BIA_TBW'] / df['Physical-Weight']\n    df['ICW_TBW'] = df['BIA-BIA_ICW'] / df['BIA-BIA_TBW']\n    df['hoursday_Age'] = df['PreInt_EduHx-computerinternet_hoursday'] / df['BMI_Age']\n\n    df['Age_Weight'] = df['Basic_Demos-Age'] * df['Physical-Weight']\n    df['Sex_BMI'] = df['Basic_Demos-Sex'] * df['Physical-BMI']\n    df['Sex_HeartRate'] = df['Basic_Demos-Sex'] * df['Physical-HeartRate']\n    df['Age_WaistCirc'] = df['Basic_Demos-Age'] * df['Physical-Waist_Circumference']\n    df['BMI_FitnessMaxStage'] = df['Physical-BMI'] * df['Fitness_Endurance-Max_Stage']\n    df['Weight_GripStrengthDominant'] = df['Physical-Weight'] * df['FGC-FGC_GSD']\n    df['Weight_GripStrengthNonDominant'] = df['Physical-Weight'] * df['FGC-FGC_GSND']\n    df['HeartRate_FitnessTime'] = df['Physical-HeartRate'] * (df['Fitness_Endurance-Time_Mins'] + df['Fitness_Endurance-Time_Sec'])\n    df['Age_PushUp'] = df['Basic_Demos-Age'] * df['FGC-FGC_PU']\n    df['FFMI_Age'] = df['BIA-BIA_FFMI'] * df['Basic_Demos-Age']\n    df['InternetUse_SleepDisturbance'] = df['PreInt_EduHx-computerinternet_hoursday'] * df['SDS-SDS_Total_Raw']\n    df['CGAS_BMI'] = df['CGAS-CGAS_Score'] * df['Physical-BMI']\n    df['CGAS_FitnessMaxStage'] = df['CGAS-CGAS_Score'] * df['Fitness_Endurance-Max_Stage']\n    \n    return df\n\ntrain = pd.read_csv('/kaggle/input/child-mind-institute-problematic-internet-use/train.csv')\ntest = pd.read_csv('/kaggle/input/child-mind-institute-problematic-internet-use/test.csv')\nsample = pd.read_csv('/kaggle/input/child-mind-institute-problematic-internet-use/sample_submission.csv')\n\ntrain_ts = load_time_series(\"/kaggle/input/child-mind-institute-problematic-internet-use/series_train.parquet\")\ntest_ts = load_time_series(\"/kaggle/input/child-mind-institute-problematic-internet-use/series_test.parquet\")\n\ndf_train = train_ts.drop('id', axis=1)\ndf_test = test_ts.drop('id', axis=1)\n\ntrain_ts_encoded = perform_autoencoder(df_train, epochs=100, batch_size=32, learning_rate=0.001, patience=10, use_pca=False, scaler_type='MinMaxScaler', sparsity_weight=1e-5)\ntest_ts_encoded = perform_autoencoder(df_test, epochs=100, batch_size=32, learning_rate=0.001, patience=10, use_pca=False, scaler_type='MinMaxScaler', sparsity_weight=1e-5)\n\ntime_series_cols = train_ts_encoded.columns.tolist()\ntrain_ts_encoded[\"id\"]=train_ts[\"id\"]\ntest_ts_encoded['id']=test_ts[\"id\"]\n\ntrain = pd.merge(train, train_ts_encoded, how=\"left\", on='id')\ntest = pd.merge(test, test_ts_encoded, how=\"left\", on='id')","metadata":{"trusted":true,"execution":{"iopub.status.busy":"2024-12-01T02:13:56.532967Z","iopub.execute_input":"2024-12-01T02:13:56.533436Z","iopub.status.idle":"2024-12-01T02:15:34.064764Z","shell.execute_reply.started":"2024-12-01T02:13:56.533396Z","shell.execute_reply":"2024-12-01T02:15:34.063309Z"}},"outputs":[],"execution_count":null},{"cell_type":"code","source":"train = train.drop('id', axis=1)\ntest_id = test[\"id\"]  # for submit\ntest = test.drop('id', axis=1)","metadata":{"trusted":true,"execution":{"iopub.status.busy":"2024-12-01T02:15:34.066357Z","iopub.execute_input":"2024-12-01T02:15:34.067195Z","iopub.status.idle":"2024-12-01T02:15:34.077794Z","shell.execute_reply.started":"2024-12-01T02:15:34.067149Z","shell.execute_reply":"2024-12-01T02:15:34.076650Z"}},"outputs":[],"execution_count":null},{"cell_type":"code","source":"imputer = KNNImputer(n_neighbors=5)\nnumeric_cols = train.select_dtypes(include=['float64', 'int64']).columns\nimputed_data = imputer.fit_transform(train[numeric_cols])\ntrain_imputed = pd.DataFrame(imputed_data, columns=numeric_cols)\ntrain_imputed['sii'] = train_imputed['sii'].round().astype(int)\nfor col in train.columns:\n    if col not in numeric_cols:\n        train_imputed[col] = train[col]\n        \ntrain = train_imputed\n\ntrain = feature_engineering(train)\ntrain = train.dropna(thresh=10, axis=0)\ntest = feature_engineering(test)","metadata":{"trusted":true,"execution":{"iopub.status.busy":"2024-12-01T02:15:34.079950Z","iopub.execute_input":"2024-12-01T02:15:34.080341Z","iopub.status.idle":"2024-12-01T02:15:42.083955Z","shell.execute_reply.started":"2024-12-01T02:15:34.080301Z","shell.execute_reply":"2024-12-01T02:15:42.082261Z"}},"outputs":[],"execution_count":null},{"cell_type":"code","source":"featuresCols = ['Basic_Demos-Age', 'Basic_Demos-Sex',\n                'CGAS-CGAS_Score', 'Physical-BMI',\n                'Physical-Height', 'Physical-Weight', 'Physical-Waist_Circumference',\n                'Physical-Diastolic_BP', 'Physical-HeartRate', 'Physical-Systolic_BP',\n                'Fitness_Endurance-Max_Stage',\n                'Fitness_Endurance-Time_Mins', 'Fitness_Endurance-Time_Sec',\n                'FGC-FGC_CU', 'FGC-FGC_CU_Zone', 'FGC-FGC_GSND',\n                'FGC-FGC_GSND_Zone', 'FGC-FGC_GSD', 'FGC-FGC_GSD_Zone', 'FGC-FGC_PU',\n                'FGC-FGC_PU_Zone', 'FGC-FGC_SRL', 'FGC-FGC_SRL_Zone', 'FGC-FGC_SRR',\n                'FGC-FGC_SRR_Zone', 'FGC-FGC_TL', 'FGC-FGC_TL_Zone',\n                'BIA-BIA_Activity_Level_num', 'BIA-BIA_BMC', 'BIA-BIA_BMI',\n                'BIA-BIA_BMR', 'BIA-BIA_DEE', 'BIA-BIA_ECW', 'BIA-BIA_FFM',\n                'BIA-BIA_FFMI', 'BIA-BIA_FMI', 'BIA-BIA_Fat', 'BIA-BIA_Frame_num',\n                'BIA-BIA_ICW', 'BIA-BIA_LDM', 'BIA-BIA_LST', 'BIA-BIA_SMM',\n                'BIA-BIA_TBW', 'PAQ_A-PAQ_A_Total',\n                'PAQ_C-PAQ_C_Total', 'SDS-SDS_Total_Raw',\n                'SDS-SDS_Total_T',\n                'PreInt_EduHx-computerinternet_hoursday', 'sii', 'BMI_Age','Internet_Hours_Age','BMI_Internet_Hours',\n                'BFP_BMI', 'FFMI_BFP', 'FMI_BFP', 'LST_TBW', 'BFP_BMR', 'BFP_DEE', 'BMR_Weight', 'DEE_Weight',\n                'SMM_Height', 'Muscle_to_Fat', 'Hydration_Status', 'ICW_TBW','Age_Weight','Sex_BMI','Sex_HeartRate','Age_WaistCirc','BMI_FitnessMaxStage','Weight_GripStrengthDominant','Weight_GripStrengthNonDominant','HeartRate_FitnessTime',\n'Age_PushUp','FFMI_Age','InternetUse_SleepDisturbance','CGAS_BMI','CGAS_FitnessMaxStage']\n\nfeaturesCols += time_series_cols\n\ntrain = train[featuresCols]\ntrain = train.dropna(subset='sii')\n\nfeaturesCols = ['Basic_Demos-Age', 'Basic_Demos-Sex',\n                'CGAS-CGAS_Score', 'Physical-BMI',\n                'Physical-Height', 'Physical-Weight', 'Physical-Waist_Circumference',\n                'Physical-Diastolic_BP', 'Physical-HeartRate', 'Physical-Systolic_BP',\n                'Fitness_Endurance-Max_Stage',\n                'Fitness_Endurance-Time_Mins', 'Fitness_Endurance-Time_Sec',\n                'FGC-FGC_CU', 'FGC-FGC_CU_Zone', 'FGC-FGC_GSND',\n                'FGC-FGC_GSND_Zone', 'FGC-FGC_GSD', 'FGC-FGC_GSD_Zone', 'FGC-FGC_PU',\n                'FGC-FGC_PU_Zone', 'FGC-FGC_SRL', 'FGC-FGC_SRL_Zone', 'FGC-FGC_SRR',\n                'FGC-FGC_SRR_Zone', 'FGC-FGC_TL', 'FGC-FGC_TL_Zone',\n                'BIA-BIA_Activity_Level_num', 'BIA-BIA_BMC', 'BIA-BIA_BMI',\n                'BIA-BIA_BMR', 'BIA-BIA_DEE', 'BIA-BIA_ECW', 'BIA-BIA_FFM',\n                'BIA-BIA_FFMI', 'BIA-BIA_FMI', 'BIA-BIA_Fat', 'BIA-BIA_Frame_num',\n                'BIA-BIA_ICW', 'BIA-BIA_LDM', 'BIA-BIA_LST', 'BIA-BIA_SMM',\n                'BIA-BIA_TBW', 'PAQ_A-PAQ_A_Total',\n                'PAQ_C-PAQ_C_Total', 'SDS-SDS_Total_Raw',\n                'SDS-SDS_Total_T',\n                'PreInt_EduHx-computerinternet_hoursday', 'BMI_Age','Internet_Hours_Age','BMI_Internet_Hours',\n                'BFP_BMI', 'FFMI_BFP', 'FMI_BFP', 'LST_TBW', 'BFP_BMR', 'BFP_DEE', 'BMR_Weight', 'DEE_Weight',\n                'SMM_Height', 'Muscle_to_Fat', 'Hydration_Status', 'ICW_TBW','Age_Weight','Sex_BMI','Sex_HeartRate','Age_WaistCirc','BMI_FitnessMaxStage','Weight_GripStrengthDominant','Weight_GripStrengthNonDominant','HeartRate_FitnessTime',\n'Age_PushUp','FFMI_Age','InternetUse_SleepDisturbance','CGAS_BMI','CGAS_FitnessMaxStage']\n\nfeaturesCols += time_series_cols\ntest = test[featuresCols]","metadata":{"trusted":true,"execution":{"iopub.status.busy":"2024-12-01T02:15:42.085475Z","iopub.execute_input":"2024-12-01T02:15:42.085978Z","iopub.status.idle":"2024-12-01T02:15:42.102922Z","shell.execute_reply.started":"2024-12-01T02:15:42.085934Z","shell.execute_reply":"2024-12-01T02:15:42.101806Z"}},"outputs":[],"execution_count":null},{"cell_type":"code","source":"train","metadata":{"trusted":true,"execution":{"iopub.status.busy":"2024-12-01T02:15:42.104403Z","iopub.execute_input":"2024-12-01T02:15:42.104779Z","iopub.status.idle":"2024-12-01T02:15:42.264228Z","shell.execute_reply.started":"2024-12-01T02:15:42.104735Z","shell.execute_reply":"2024-12-01T02:15:42.263011Z"}},"outputs":[],"execution_count":null},{"cell_type":"code","source":"test","metadata":{"trusted":true,"execution":{"iopub.status.busy":"2024-12-01T02:15:42.265857Z","iopub.execute_input":"2024-12-01T02:15:42.266312Z","iopub.status.idle":"2024-12-01T02:15:42.456354Z","shell.execute_reply.started":"2024-12-01T02:15:42.266258Z","shell.execute_reply":"2024-12-01T02:15:42.455193Z"}},"outputs":[],"execution_count":null},{"cell_type":"code","source":"if np.any(np.isinf(train)):\n    train = train.replace([np.inf, -np.inf], np.nan)\ntrain_df_le = train\ntest_df_le = test","metadata":{"trusted":true,"execution":{"iopub.status.busy":"2024-12-01T02:15:42.460606Z","iopub.execute_input":"2024-12-01T02:15:42.461124Z","iopub.status.idle":"2024-12-01T02:15:42.476168Z","shell.execute_reply.started":"2024-12-01T02:15:42.461068Z","shell.execute_reply":"2024-12-01T02:15:42.474873Z"}},"outputs":[],"execution_count":null},{"cell_type":"code","source":"# DBSCAN clustering\n\nimport numpy as np\nimport pandas as pd\nfrom sklearn.impute import SimpleImputer\nfrom sklearn.pipeline import Pipeline\nfrom sklearn.preprocessing import StandardScaler\nfrom sklearn.cluster import DBSCAN\nfrom sklearn.manifold import TSNE\nimport matplotlib.pyplot as plt\nimport seaborn as sns\n\n# Save the 'sii' column\ntrain_sii = train_df_le['sii'].copy()\n\n# Find common columns between train and test data\ncommon_columns = train_df_le.columns.intersection(test_df_le.columns)\ntrain_df_le = train_df_le[common_columns]\ntest_df_le = test_df_le[common_columns]\ntrain_df_le['sii'] = train_sii\n\n# Pipeline: Fill missing values with the mean\npreprocessor = Pipeline(steps=[\n    ('imputer', SimpleImputer(strategy='mean')), \n])\n\ny = train_df_le['sii']\ntrain_df_le = train_df_le.drop(columns=['sii'])\ntrain_df_le = preprocessor.fit_transform(train_df_le)\ntrain_df_le = pd.DataFrame(train_df_le, columns=common_columns)\ntrain_df_le['sii'] = y\n\n# Standardize numerical columns\nnumeric_cols = train_df_le.select_dtypes(include=[np.number]).columns  \nnumeric_cols = numeric_cols.drop('sii')  # Exclude 'sii'\nscaler = StandardScaler()\ntrain_df_le[numeric_cols] = scaler.fit_transform(train_df_le[numeric_cols])\n\n# Preprocess the test data\ntest_df_le = preprocessor.transform(test_df_le)\ntest_df_le = pd.DataFrame(test_df_le, columns=common_columns)\ntest_df_le[numeric_cols] = scaler.transform(test_df_le[numeric_cols])\n\n# Perform DBSCAN clustering\ndbscan = DBSCAN(eps=2.5, min_samples=25)  \ntrain_clusters = dbscan.fit_predict(train_df_le)\n\nprint(f\"Unique clusters: {len(np.unique(train_clusters[train_clusters != -1]))}\")\nprint(f\"Noise points: {np.sum(train_clusters == -1)}\")\n\n# Find the mode of 'sii' for each cluster\ncluster_modes = pd.Series(index=np.unique(train_clusters), dtype=float)\n\nfor cluster_num in np.unique(train_clusters):  \n    cluster_rows = train_df_le[train_clusters == cluster_num]\n    cluster_sii = y[train_clusters == cluster_num]  # 'sii'\n    cluster_modes[cluster_num] = cluster_sii.mode()[0] \n\nprint(\"Cluster 'sii' modes:\")\nprint(cluster_modes)\n\n# Fill missing 'sii' values based on the cluster modes\ntrain_df_le.loc[train_df_le['sii'].isnull(), 'sii'] = [\n    cluster_modes[train_clusters[i]] for i in range(len(train_clusters))\n]\nX = train_df_le\n\n# Perform t-SNE to reduce dimensions to 3D for visualization\ntsne = TSNE(n_components=3, random_state=42, perplexity=30, n_iter=300)\ntrain_df_le_tsne = tsne.fit_transform(train_df_le)\n\n# DBSCAN clustering results (-1 indicates noise)\ntrain_clusters = dbscan.labels_\n\n# Set up the plot size and layout (4 subplots: 3D, 2D, Bar Chart)\nfig, axes = plt.subplots(2, 2, figsize=(18, 12), dpi=80, subplot_kw={'projection': None})\n\n# Define custom color palette for clusters\nnum_clusters = len(np.unique(train_clusters)) - 1  # Exclude noise (-1)\npalette = sns.color_palette(\"Set3\", n_colors=num_clusters)\n\n# Plot 1: Clusters (2D scatter using t-SNE components 1 & 2)\nax1 = axes[0, 0]\nfor cluster_num in np.unique(train_clusters):\n    if cluster_num == -1:  # Noise points\n        ax1.scatter(train_df_le_tsne[train_clusters == cluster_num, 0], \n                    train_df_le_tsne[train_clusters == cluster_num, 1], \n                    color='lightgray', label='Noise', s=30, edgecolor='k', marker='X')\n    else:\n        ax1.scatter(train_df_le_tsne[train_clusters == cluster_num, 0], \n                    train_df_le_tsne[train_clusters == cluster_num, 1], \n                    color=palette[cluster_num % len(palette)], \n                    label=f'Cluster {cluster_num}', s=80, edgecolor='k')\n\nax1.set_title('DBSCAN Clustering (t-SNE 2D)', fontsize=16, weight='bold')\nax1.set_xlabel('t-SNE Component 1', fontsize=14)\nax1.set_ylabel('t-SNE Component 2', fontsize=14)\n\n# Plot 2: Clusters Only (3D scatter)\nax2 = fig.add_subplot(222, projection='3d')\nfor cluster_num in np.unique(train_clusters):\n    if cluster_num != -1:  # Exclude Noise points\n        ax2.scatter(train_df_le_tsne[train_clusters == cluster_num, 0], \n                    train_df_le_tsne[train_clusters == cluster_num, 1], \n                    train_df_le_tsne[train_clusters == cluster_num, 2], \n                    color=palette[cluster_num % len(palette)], \n                    label=f'Cluster {cluster_num}', s=80, edgecolor='k')\n\nax2.set_title('Clusters Without Noise (t-SNE 3D)', fontsize=16, weight='bold')\nax2.set_xlabel('t-SNE Component 1', fontsize=14)\nax2.set_ylabel('t-SNE Component 2', fontsize=14)\nax2.set_zlabel('t-SNE Component 3', fontsize=14)\n\n# Bar chart: Cluster Sizes\nax3 = axes[1, 0]\ncluster_sizes = pd.Series(train_clusters).value_counts().sort_index()\ncluster_sizes = cluster_sizes[cluster_sizes.index != -1]  # Exclude Noise\n\nax3.bar(cluster_sizes.index, cluster_sizes.values, color=palette[:len(cluster_sizes)])\nax3.set_title('Cluster Sizes', fontsize=16, weight='bold')\nax3.set_xlabel('Cluster Number', fontsize=14)\nax3.set_ylabel('Number of Points', fontsize=14)\n\n# Remove the unnecessary fourth plot (bottom-right)\nfig.delaxes(axes[1, 1])\n\n# Add legend\nhandles, labels = ax1.get_legend_handles_labels()\nfig.legend(handles, labels, loc='center left', bbox_to_anchor=(1, 0.5), fontsize=12, title=\"Clusters\")\n\nplt.tight_layout()\nplt.show()\n","metadata":{"trusted":true,"execution":{"iopub.status.busy":"2024-12-01T02:15:42.478101Z","iopub.execute_input":"2024-12-01T02:15:42.478907Z","iopub.status.idle":"2024-12-01T02:16:03.612968Z","shell.execute_reply.started":"2024-12-01T02:15:42.478849Z","shell.execute_reply":"2024-12-01T02:16:03.611909Z"}},"outputs":[],"execution_count":null},{"cell_type":"code","source":"# 'sii' \ny = X['sii']\nX = X.drop(columns=['sii'])\nX.info()","metadata":{"trusted":true,"execution":{"iopub.status.busy":"2024-12-01T02:16:03.614290Z","iopub.execute_input":"2024-12-01T02:16:03.614669Z","iopub.status.idle":"2024-12-01T02:16:03.646258Z","shell.execute_reply.started":"2024-12-01T02:16:03.614630Z","shell.execute_reply":"2024-12-01T02:16:03.645026Z"}},"outputs":[],"execution_count":null},{"cell_type":"code","source":"# Convert numpy.ndarray to pandas DataFrame\ntest_df_le = pd.DataFrame(test_df_le)\n\n# Now you can use .info() to inspect the DataFrame\ntest_df_le.info()\ntest_df_le.columns = X.columns\nX_test = test_df_le","metadata":{"trusted":true,"execution":{"iopub.status.busy":"2024-12-01T02:16:03.647586Z","iopub.execute_input":"2024-12-01T02:16:03.647963Z","iopub.status.idle":"2024-12-01T02:16:03.665032Z","shell.execute_reply.started":"2024-12-01T02:16:03.647929Z","shell.execute_reply":"2024-12-01T02:16:03.663923Z"}},"outputs":[],"execution_count":null},{"cell_type":"code","source":"# Model parameters\n\nSEED = 42\n# LGBM\nLGBM_Params = {\n    'learning_rate': 0.0399, # 0.0399\n    'max_depth': 14, # 12 -> 14\n    'num_leaves': 478,\n    'min_data_in_leaf': 13,\n    'feature_fraction': 0.893,\n    'bagging_fraction': 0.784,\n    'bagging_freq': 4,\n    'lambda_l1': 3, # 10\n    'lambda_l2': 0.3, # 0.3\n    'random_state': SEED\n}\n\n# XGBoost\nXGB_Params = {\n    'learning_rate': 0.03, # 0.03\n    'max_depth': 10, # 10\n    'n_estimators': 300, # 300\n    'subsample': 0.8, # 0.8\n    'colsample_bytree': 0.8, # 0.8\n    'gamma': 2,\n    'reg_alpha': 1,  # 1\n    'reg_lambda': 3, # 3\n    'random_state': SEED\n}\n\n# CatBoost\nCatBoost_Params = {\n    'learning_rate': 0.045, # 0.05\n    'depth': 10, # 6 -> 10\n    'iterations': 300, # 200\n    'random_seed': SEED,\n    'verbose': 0,\n    'l2_leaf_reg': 10\n}","metadata":{"trusted":true,"execution":{"iopub.status.busy":"2024-12-01T02:16:03.666395Z","iopub.execute_input":"2024-12-01T02:16:03.666785Z","iopub.status.idle":"2024-12-01T02:16:03.681096Z","shell.execute_reply.started":"2024-12-01T02:16:03.666734Z","shell.execute_reply":"2024-12-01T02:16:03.679800Z"}},"outputs":[],"execution_count":null},{"cell_type":"code","source":"# PyTorch Regressor definition\n\nclass PyTorchRegressor(BaseEstimator, RegressorMixin):\n    def __init__(self, input_dim=None, hidden_dim=128, epochs=100, batch_size=32, learning_rate=1e-4, seed=42, device='cpu'):\n        self.hidden_dim = hidden_dim\n        self.epochs = epochs\n        self.batch_size = batch_size\n        self.learning_rate = learning_rate\n        self.seed = seed\n        self.device = device\n        self.input_dim = input_dim\n        self.model = None\n        self.scaler = StandardScaler()\n        self.y_mean = None\n        self.y_std = None\n\n    def _build_model(self):\n        model = nn.Sequential(\n            nn.Linear(self.input_dim, self.hidden_dim),\n            nn.ReLU(),\n            nn.Dropout(p=0.3),\n            nn.Linear(self.hidden_dim, self.hidden_dim),\n            nn.ReLU(),\n            nn.Dropout(p=0.3),\n            nn.Linear(self.hidden_dim, 1)\n        )\n        return model.to(self.device)\n\n    def fit(self, X, y):\n        self.input_dim = X.shape[1]\n        self.model = self._build_model()\n        self.model.train()\n        X_scaled = self.scaler.fit_transform(X)\n        X_tensor = torch.tensor(X_scaled, dtype=torch.float32).to(self.device)\n\n        self.y_mean, self.y_std = y.mean(), y.std()\n        if isinstance(y, pd.Series):\n            y_scaled = (y - self.y_mean) / self.y_std\n            y_tensor = torch.tensor(y_scaled.values, dtype=torch.float32).view(-1, 1).to(self.device)\n        else:\n            y_scaled = (y - self.y_mean) / self.y_std\n            y_tensor = torch.tensor(y_scaled, dtype=torch.float32).view(-1, 1).to(self.device)\n\n        dataset = torch.utils.data.TensorDataset(X_tensor, y_tensor)\n        dataloader = torch.utils.data.DataLoader(dataset, batch_size=self.batch_size, shuffle=True)\n\n        self.optimizer = optim.Adam(self.model.parameters(), lr=self.learning_rate)\n        self.criterion = nn.MSELoss()\n\n        for epoch in range(self.epochs):\n            epoch_loss = 0.0\n            for batch_X, batch_y in dataloader:\n                self.optimizer.zero_grad()\n                outputs = self.model(batch_X)\n                loss = self.criterion(outputs, batch_y)\n                loss.backward()\n                self.optimizer.step()\n                epoch_loss += loss.item()\n\n            if epoch % 10 == 0:\n                print(f\"Epoch [{epoch}/{self.epochs}], Loss: {epoch_loss/len(dataloader):.4f}\")\n\n        return self\n\n    def predict(self, X):\n        self.model.eval()\n        with torch.no_grad():\n            X_scaled = self.scaler.transform(X)\n            X_tensor = torch.tensor(X_scaled, dtype=torch.float32).to(self.device)\n            outputs = self.model(X_tensor).squeeze().cpu().numpy()\n            return outputs * self.y_std + self.y_mean\n\n\n# QWK optimization function\ndef evaluate_predictions(thresholds, y_true, y_pred):\n    thresholds = np.sort(thresholds)\n    y_pred_classes = np.digitize(y_pred, thresholds)\n    return -cohen_kappa_score(y_true, y_pred_classes, weights='quadratic')\n\n\n# Initialize thresholds dynamically based on quantiles of predicted values\ndef calculate_initial_thresholds(y_pred):\n    # Dynamically calculate thresholds based on quantiles (e.g., 3 quantiles for 3 classes)\n    return np.percentile(y_pred, [33, 66])\n\n# Meta-model and hyperparameters optimization using Optuna\nstudy = optuna.create_study(direction='maximize')\n\ndef objective(trial):\n    hidden_dim = trial.suggest_int('hidden_dim', 64, 256, step=64)\n    epochs = trial.suggest_int('epochs', 50, 200, step=50)\n    batch_size = trial.suggest_int('batch_size', 16, 128, step=16)\n    learning_rate = trial.suggest_float('learning_rate', 1e-4, 1e-2, log=True)\n    alpha = trial.suggest_float('alpha', 1e-4, 10.0, log=True)\n\n    pytorch_model = PyTorchRegressor(input_dim=X.shape[1], hidden_dim=hidden_dim,\n                                     epochs=epochs, batch_size=batch_size,\n                                     learning_rate=learning_rate, seed=42,\n                                     device='cuda' if torch.cuda.is_available() else 'cpu')\n    scores = []\n    for train_idx, valid_idx in KFold(n_splits=5, shuffle=True, random_state=42).split(X, y):\n        X_train, X_valid = X.iloc[train_idx], X.iloc[valid_idx]\n        y_train, y_valid = y.iloc[train_idx], y.iloc[valid_idx]\n\n        pytorch_model.fit(X_train, y_train)\n        preds = pytorch_model.predict(X_valid)\n\n        initial_thresholds = calculate_initial_thresholds(preds)\n        KappaOptimizer = minimize(evaluate_predictions, x0=initial_thresholds,\n                                  args=(y_valid, preds), method='Nelder-Mead')\n        best_thresholds = np.sort(KappaOptimizer.x)\n        preds_class = np.digitize(preds, best_thresholds)\n\n        qwk_score = cohen_kappa_score(y_valid, preds_class, weights='quadratic')\n        scores.append(qwk_score)\n\n    return np.mean(scores)\n\nstudy.optimize(objective, n_trials=50)\nbest_params = study.best_params\n\n# Create optimized hyperparameters\npytorch_model = PyTorchRegressor(input_dim=X.shape[1], \n                                 hidden_dim=best_params['hidden_dim'], \n                                 epochs=best_params['epochs'], \n                                 batch_size=best_params['batch_size'], \n                                 learning_rate=best_params['learning_rate'], \n                                 device='cuda' if torch.cuda.is_available() else 'cpu')","metadata":{"trusted":true,"execution":{"iopub.status.busy":"2024-12-01T02:16:03.682701Z","iopub.execute_input":"2024-12-01T02:16:03.683136Z","iopub.status.idle":"2024-12-01T03:12:17.378062Z","shell.execute_reply.started":"2024-12-01T02:16:03.683086Z","shell.execute_reply":"2024-12-01T03:12:17.376926Z"}},"outputs":[],"execution_count":null},{"cell_type":"code","source":"# Create and train the stacking model \n\n# WeightedAveragingRegressor\nclass WeightedAveragingRegressor(RegressorMixin, BaseEstimator):\n    def __init__(self, estimators, weights=None):\n        self.estimators = estimators\n        self.weights = weights if weights is not None else [1 / len(estimators)] * len(estimators)\n    \n    def fit(self, X, y):\n        for name, model in self.estimators:\n            model.fit(X, y)\n        return self\n    \n    def predict(self, X):\n        predictions = np.array([model.predict(X) for _, model in self.estimators])\n        return np.dot(self.weights, predictions)\n\nbase_models = [\n    ('lgb', LGBMRegressor(**LGBM_Params)),\n    ('xgb', XGBRegressor(**XGB_Params)),\n    ('cat', CatBoostRegressor(**CatBoost_Params)),\n    ('pytorch', pytorch_model)  \n]\n\nweights = [0.3, 0.3, 0.2, 0.2]\nstacking_model = WeightedAveragingRegressor(base_models, weights=weights)\n\n# kf\nkf = KFold(n_splits=10, shuffle=True, random_state=42)\ntest_predictions = np.zeros(test_df_le.shape[0])\nqwk_scores = []\n\nfor fold, (train_idx, valid_idx) in enumerate(kf.split(X, y), 1):\n    X_train, X_valid = X.iloc[train_idx], X.iloc[valid_idx]\n    y_train, y_valid = y.iloc[train_idx], y.iloc[valid_idx]\n\n    # evaluate_predictions\n    stacking_model.fit(X_train, y_train)\n    preds = stacking_model.predict(X_valid)\n\n    # evaluate_predictions\n    def evaluate_predictions(thresholds, y_true, y_pred):\n        preds_class = np.digitize(y_pred, np.sort(thresholds))\n        return -cohen_kappa_score(y_true, preds_class, weights='quadratic')\n    \n    initial_thresholds = np.linspace(preds.min(), preds.max(), 4)\n    KappaOptimizer = minimize(evaluate_predictions, x0=initial_thresholds,\n                              args=(y_valid, preds), method='Nelder-Mead')\n    best_thresholds = np.sort(KappaOptimizer.x)\n    preds_class = np.digitize(preds, best_thresholds)\n\n    # QWK\n    qwk_score = cohen_kappa_score(y_valid, preds_class, weights='quadratic')\n    qwk_scores.append(qwk_score)\n\n    # test_preds\n    test_preds = stacking_model.predict(test_df_le)\n    test_predictions += test_preds / kf.n_splits\n\n    print(f\"Fold {fold}: QWK = {qwk_score:.4f}\")\n\n# Average QWK\nprint(f\"Average QWK score across folds: {np.mean(qwk_scores):.4f}\")\n\n# Prepare the test predictions for submission\ntest_pred_classes = np.digitize(test_predictions, np.sort(best_thresholds))\n\n# Clip values to be within the expected range (0 to 3)\ntest_pred_classes = np.clip(test_pred_classes, 0, 3)\n\n# Create the submission DataFrame\nSubmission1 = pd.DataFrame({'id': test_id, 'sii': test_pred_classes.astype(int)})\n\n# Save the submission to a CSV file\n# Submission1.to_csv('submission.csv', index=False)\n\n# Display the first few rows of the submission DataFrame\nprint(Submission1)\n","metadata":{"trusted":true,"execution":{"iopub.status.busy":"2024-12-01T03:12:17.380060Z","iopub.execute_input":"2024-12-01T03:12:17.380568Z","iopub.status.idle":"2024-12-01T03:24:48.379708Z","shell.execute_reply.started":"2024-12-01T03:12:17.380487Z","shell.execute_reply":"2024-12-01T03:24:48.378453Z"}},"outputs":[],"execution_count":null},{"cell_type":"code","source":"print(Submission1)","metadata":{"trusted":true,"execution":{"iopub.status.busy":"2024-12-01T03:24:48.381261Z","iopub.execute_input":"2024-12-01T03:24:48.381631Z","iopub.status.idle":"2024-12-01T03:24:48.389333Z","shell.execute_reply.started":"2024-12-01T03:24:48.381589Z","shell.execute_reply":"2024-12-01T03:24:48.388006Z"}},"outputs":[],"execution_count":null},{"cell_type":"code","source":"train = pd.read_csv('/kaggle/input/child-mind-institute-problematic-internet-use/train.csv')\ntest = pd.read_csv('/kaggle/input/child-mind-institute-problematic-internet-use/test.csv')\nsample = pd.read_csv('/kaggle/input/child-mind-institute-problematic-internet-use/sample_submission.csv')\n\ndef process_file(filename, dirname):\n    df = pd.read_parquet(os.path.join(dirname, filename, 'part-0.parquet'))\n    df.drop('step', axis=1, inplace=True)\n    return df.describe().values.reshape(-1), filename.split('=')[1]\n\ndef load_time_series(dirname) -> pd.DataFrame:\n    ids = os.listdir(dirname)\n    \n    with ThreadPoolExecutor() as executor:\n        results = list(tqdm(executor.map(lambda fname: process_file(fname, dirname), ids), total=len(ids)))\n    \n    stats, indexes = zip(*results)\n    \n    df = pd.DataFrame(stats, columns=[f\"stat_{i}\" for i in range(len(stats[0]))])\n    df['id'] = indexes\n    return df\n        \ntrain_ts = load_time_series(\"/kaggle/input/child-mind-institute-problematic-internet-use/series_train.parquet\")\ntest_ts = load_time_series(\"/kaggle/input/child-mind-institute-problematic-internet-use/series_test.parquet\")\n\ntime_series_cols = train_ts.columns.tolist()\ntime_series_cols.remove(\"id\")\n\ntrain = pd.merge(train, train_ts, how=\"left\", on='id')\ntest = pd.merge(test, test_ts, how=\"left\", on='id')\n\ntrain = train.drop('id', axis=1)\ntest = test.drop('id', axis=1)   \n\nfeaturesCols = ['Basic_Demos-Enroll_Season', 'Basic_Demos-Age', 'Basic_Demos-Sex',\n                'CGAS-Season', 'CGAS-CGAS_Score', 'Physical-Season', 'Physical-BMI',\n                'Physical-Height', 'Physical-Weight', 'Physical-Waist_Circumference',\n                'Physical-Diastolic_BP', 'Physical-HeartRate', 'Physical-Systolic_BP',\n                'Fitness_Endurance-Season', 'Fitness_Endurance-Max_Stage',\n                'Fitness_Endurance-Time_Mins', 'Fitness_Endurance-Time_Sec',\n                'FGC-Season', 'FGC-FGC_CU', 'FGC-FGC_CU_Zone', 'FGC-FGC_GSND',\n                'FGC-FGC_GSND_Zone', 'FGC-FGC_GSD', 'FGC-FGC_GSD_Zone', 'FGC-FGC_PU',\n                'FGC-FGC_PU_Zone', 'FGC-FGC_SRL', 'FGC-FGC_SRL_Zone', 'FGC-FGC_SRR',\n                'FGC-FGC_SRR_Zone', 'FGC-FGC_TL', 'FGC-FGC_TL_Zone', 'BIA-Season',\n                'BIA-BIA_Activity_Level_num', 'BIA-BIA_BMC', 'BIA-BIA_BMI',\n                'BIA-BIA_BMR', 'BIA-BIA_DEE', 'BIA-BIA_ECW', 'BIA-BIA_FFM',\n                'BIA-BIA_FFMI', 'BIA-BIA_FMI', 'BIA-BIA_Fat', 'BIA-BIA_Frame_num',\n                'BIA-BIA_ICW', 'BIA-BIA_LDM', 'BIA-BIA_LST', 'BIA-BIA_SMM',\n                'BIA-BIA_TBW', 'PAQ_A-Season', 'PAQ_A-PAQ_A_Total', 'PAQ_C-Season',\n                'PAQ_C-PAQ_C_Total', 'SDS-Season', 'SDS-SDS_Total_Raw',\n                'SDS-SDS_Total_T', 'PreInt_EduHx-Season',\n                'PreInt_EduHx-computerinternet_hoursday', 'sii']\n\nfeaturesCols += time_series_cols\n\ntrain = train[featuresCols]\ntrain = train.dropna(subset='sii')\n\ncat_c = ['Basic_Demos-Enroll_Season', 'CGAS-Season', 'Physical-Season', \n          'Fitness_Endurance-Season', 'FGC-Season', 'BIA-Season', \n          'PAQ_A-Season', 'PAQ_C-Season', 'SDS-Season', 'PreInt_EduHx-Season']\n\ndef update(df):\n    global cat_c\n    for c in cat_c: \n        df[c] = df[c].fillna('Missing')\n        df[c] = df[c].astype('category')\n    return df\n        \ntrain = update(train)\ntest = update(test)\n\ndef create_mapping(column, dataset):\n    unique_values = dataset[column].unique()\n    return {value: idx for idx, value in enumerate(unique_values)}\n\nfor col in cat_c:\n    mapping = create_mapping(col, train)\n    mappingTe = create_mapping(col, test)\n    \n    train[col] = train[col].replace(mapping).astype(int)\n    test[col] = test[col].replace(mappingTe).astype(int)\n\ndef quadratic_weighted_kappa(y_true, y_pred):\n    return cohen_kappa_score(y_true, y_pred, weights='quadratic')\n\ndef threshold_Rounder(oof_non_rounded, thresholds):\n    return np.where(oof_non_rounded < thresholds[0], 0,\n                    np.where(oof_non_rounded < thresholds[1], 1,\n                             np.where(oof_non_rounded < thresholds[2], 2, 3)))\n\ndef evaluate_predictions(thresholds, y_true, oof_non_rounded):\n    rounded_p = threshold_Rounder(oof_non_rounded, thresholds)\n    return -quadratic_weighted_kappa(y_true, rounded_p)\n\ndef TrainML(model_class, test_data):\n    X = train.drop(['sii'], axis=1)\n    y = train['sii']\n\n    SKF = StratifiedKFold(n_splits=n_splits, shuffle=True, random_state=SEED)\n    \n    train_S = []\n    test_S = []\n    \n    oof_non_rounded = np.zeros(len(y), dtype=float) \n    oof_rounded = np.zeros(len(y), dtype=int) \n    test_preds = np.zeros((len(test_data), n_splits))\n\n    for fold, (train_idx, test_idx) in enumerate(tqdm(SKF.split(X, y), desc=\"Training Folds\", total=n_splits)):\n        X_train, X_val = X.iloc[train_idx], X.iloc[test_idx]\n        y_train, y_val = y.iloc[train_idx], y.iloc[test_idx]\n\n        model = clone(model_class)\n        model.fit(X_train, y_train)\n\n        y_train_pred = model.predict(X_train)\n        y_val_pred = model.predict(X_val)\n\n        oof_non_rounded[test_idx] = y_val_pred\n        y_val_pred_rounded = y_val_pred.round(0).astype(int)\n        oof_rounded[test_idx] = y_val_pred_rounded\n\n        train_kappa = quadratic_weighted_kappa(y_train, y_train_pred.round(0).astype(int))\n        val_kappa = quadratic_weighted_kappa(y_val, y_val_pred_rounded)\n\n        train_S.append(train_kappa)\n        test_S.append(val_kappa)\n        \n        test_preds[:, fold] = model.predict(test_data)\n        \n        print(f\"Fold {fold+1} - Train QWK: {train_kappa:.4f}, Validation QWK: {val_kappa:.4f}\")\n        clear_output(wait=True)\n\n    print(f\"Mean Train QWK --> {np.mean(train_S):.4f}\")\n    print(f\"Mean Validation QWK ---> {np.mean(test_S):.4f}\")\n\n    KappaOPtimizer = minimize(evaluate_predictions,\n                              x0=[0.5, 1.5, 2.5], args=(y, oof_non_rounded), \n                              method='Nelder-Mead')\n    assert KappaOPtimizer.success, \"Optimization did not converge.\"\n    \n    oof_tuned = threshold_Rounder(oof_non_rounded, KappaOPtimizer.x)\n    tKappa = quadratic_weighted_kappa(y, oof_tuned)\n\n    print(f\"----> || Optimized QWK SCORE :: {Fore.CYAN}{Style.BRIGHT} {tKappa:.3f}{Style.RESET_ALL}\")\n\n    tpm = test_preds.mean(axis=1)\n    tpTuned = threshold_Rounder(tpm, KappaOPtimizer.x)\n    \n    submission = pd.DataFrame({\n        'id': sample['id'],\n        'sii': tpTuned\n    })\n\n    return submission\n\n# Model parameters for LightGBM\nParams = {\n    'learning_rate': 0.046,\n    'max_depth': 12,\n    'num_leaves': 478,\n    'min_data_in_leaf': 13,\n    'feature_fraction': 0.893,\n    'bagging_fraction': 0.784,\n    'bagging_freq': 4,\n    'lambda_l1': 10,  # Increased from 6.59\n    'lambda_l2': 0.01  # Increased from 2.68e-06\n}\n\n\n# XGBoost parameters\nXGB_Params = {\n    'learning_rate': 0.05,\n    'max_depth': 6,\n    'n_estimators': 200,\n    'subsample': 0.8,\n    'colsample_bytree': 0.8,\n    'reg_alpha': 1,  # Increased from 0.1\n    'reg_lambda': 5,  # Increased from 1\n    'random_state': SEED\n}\n\n\nCatBoost_Params = {\n    'learning_rate': 0.05,\n    'depth': 6,\n    'iterations': 200,\n    'random_seed': SEED,\n    'cat_features': cat_c,\n    'verbose': 0,\n    'l2_leaf_reg': 10  # Increase this value\n}\n\n# Create model instances\nLight = LGBMRegressor(**Params, random_state=SEED, verbose=-1, n_estimators=300)\nXGB_Model = XGBRegressor(**XGB_Params)\nCatBoost_Model = CatBoostRegressor(**CatBoost_Params)\n\n# Combine models using Voting Regressor\nvoting_model = VotingRegressor(estimators=[\n    ('lightgbm', Light),\n    ('xgboost', XGB_Model),\n    ('catboost', CatBoost_Model)\n])\n\n# Train the ensemble model\nSubmission2 = TrainML(voting_model, test)\n\n# Save submission\n#Submission2.to_csv('submission.csv', index=False)\nSubmission2","metadata":{"trusted":true,"execution":{"iopub.status.busy":"2024-12-01T03:24:48.391422Z","iopub.execute_input":"2024-12-01T03:24:48.391897Z","iopub.status.idle":"2024-12-01T03:27:37.459715Z","shell.execute_reply.started":"2024-12-01T03:24:48.391844Z","shell.execute_reply":"2024-12-01T03:27:37.458393Z"}},"outputs":[],"execution_count":null},{"cell_type":"code","source":"train = pd.read_csv('/kaggle/input/child-mind-institute-problematic-internet-use/train.csv')\ntest = pd.read_csv('/kaggle/input/child-mind-institute-problematic-internet-use/test.csv')\nsample = pd.read_csv('/kaggle/input/child-mind-institute-problematic-internet-use/sample_submission.csv')\n\nfeaturesCols = ['Basic_Demos-Enroll_Season', 'Basic_Demos-Age', 'Basic_Demos-Sex',\n                'CGAS-Season', 'CGAS-CGAS_Score', 'Physical-Season', 'Physical-BMI',\n                'Physical-Height', 'Physical-Weight', 'Physical-Waist_Circumference',\n                'Physical-Diastolic_BP', 'Physical-HeartRate', 'Physical-Systolic_BP',\n                'Fitness_Endurance-Season', 'Fitness_Endurance-Max_Stage',\n                'Fitness_Endurance-Time_Mins', 'Fitness_Endurance-Time_Sec',\n                'FGC-Season', 'FGC-FGC_CU', 'FGC-FGC_CU_Zone', 'FGC-FGC_GSND',\n                'FGC-FGC_GSND_Zone', 'FGC-FGC_GSD', 'FGC-FGC_GSD_Zone', 'FGC-FGC_PU',\n                'FGC-FGC_PU_Zone', 'FGC-FGC_SRL', 'FGC-FGC_SRL_Zone', 'FGC-FGC_SRR',\n                'FGC-FGC_SRR_Zone', 'FGC-FGC_TL', 'FGC-FGC_TL_Zone', 'BIA-Season',\n                'BIA-BIA_Activity_Level_num', 'BIA-BIA_BMC', 'BIA-BIA_BMI',\n                'BIA-BIA_BMR', 'BIA-BIA_DEE', 'BIA-BIA_ECW', 'BIA-BIA_FFM',\n                'BIA-BIA_FFMI', 'BIA-BIA_FMI', 'BIA-BIA_Fat', 'BIA-BIA_Frame_num',\n                'BIA-BIA_ICW', 'BIA-BIA_LDM', 'BIA-BIA_LST', 'BIA-BIA_SMM',\n                'BIA-BIA_TBW', 'PAQ_A-Season', 'PAQ_A-PAQ_A_Total', 'PAQ_C-Season',\n                'PAQ_C-PAQ_C_Total', 'SDS-Season', 'SDS-SDS_Total_Raw',\n                'SDS-SDS_Total_T', 'PreInt_EduHx-Season',\n                'PreInt_EduHx-computerinternet_hoursday', 'sii']\n\ncat_c = ['Basic_Demos-Enroll_Season', 'CGAS-Season', 'Physical-Season', \n          'Fitness_Endurance-Season', 'FGC-Season', 'BIA-Season', \n          'PAQ_A-Season', 'PAQ_C-Season', 'SDS-Season', 'PreInt_EduHx-Season']\n\ntrain_ts = load_time_series(\"/kaggle/input/child-mind-institute-problematic-internet-use/series_train.parquet\")\ntest_ts = load_time_series(\"/kaggle/input/child-mind-institute-problematic-internet-use/series_test.parquet\")\n\ntime_series_cols = train_ts.columns.tolist()\ntime_series_cols.remove(\"id\")\n\ntrain = pd.merge(train, train_ts, how=\"left\", on='id')\ntest = pd.merge(test, test_ts, how=\"left\", on='id')\n\ntrain = train.drop('id', axis=1)\ntest = test.drop('id', axis=1)\n\nfeaturesCols += time_series_cols\n\ntrain = train[featuresCols]\ntrain = train.dropna(subset='sii')\n\ndef update(df):\n    global cat_c\n    for c in cat_c: \n        df[c] = df[c].fillna('Missing')\n        df[c] = df[c].astype('category')\n    return df\n\ntrain = update(train)\ntest = update(test)\n\ndef create_mapping(column, dataset):\n    unique_values = dataset[column].unique()\n    return {value: idx for idx, value in enumerate(unique_values)}\n\nfor col in cat_c:\n    mapping = create_mapping(col, train)\n    mappingTe = create_mapping(col, test)\n    \n    train[col] = train[col].replace(mapping).astype(int)\n    test[col] = test[col].replace(mappingTe).astype(int)\n\ndef quadratic_weighted_kappa(y_true, y_pred):\n    return cohen_kappa_score(y_true, y_pred, weights='quadratic')\n\ndef threshold_Rounder(oof_non_rounded, thresholds):\n    return np.where(oof_non_rounded < thresholds[0], 0,\n                    np.where(oof_non_rounded < thresholds[1], 1,\n                             np.where(oof_non_rounded < thresholds[2], 2, 3)))\n\ndef evaluate_predictions(thresholds, y_true, oof_non_rounded):\n    rounded_p = threshold_Rounder(oof_non_rounded, thresholds)\n    return -quadratic_weighted_kappa(y_true, rounded_p)\n\ndef TrainML(model_class, test_data):\n    X = train.drop(['sii'], axis=1)\n    y = train['sii']\n\n    SKF = StratifiedKFold(n_splits=n_splits, shuffle=True, random_state=SEED)\n    \n    train_S = []\n    test_S = []\n    \n    oof_non_rounded = np.zeros(len(y), dtype=float) \n    oof_rounded = np.zeros(len(y), dtype=int) \n    test_preds = np.zeros((len(test_data), n_splits))\n\n    for fold, (train_idx, test_idx) in enumerate(tqdm(SKF.split(X, y), desc=\"Training Folds\", total=n_splits)):\n        X_train, X_val = X.iloc[train_idx], X.iloc[test_idx]\n        y_train, y_val = y.iloc[train_idx], y.iloc[test_idx]\n\n        model = clone(model_class)\n        model.fit(X_train, y_train)\n\n        y_train_pred = model.predict(X_train)\n        y_val_pred = model.predict(X_val)\n\n        oof_non_rounded[test_idx] = y_val_pred\n        y_val_pred_rounded = y_val_pred.round(0).astype(int)\n        oof_rounded[test_idx] = y_val_pred_rounded\n\n        train_kappa = quadratic_weighted_kappa(y_train, y_train_pred.round(0).astype(int))\n        val_kappa = quadratic_weighted_kappa(y_val, y_val_pred_rounded)\n\n        train_S.append(train_kappa)\n        test_S.append(val_kappa)\n        \n        test_preds[:, fold] = model.predict(test_data)\n        \n        print(f\"Fold {fold+1} - Train QWK: {train_kappa:.4f}, Validation QWK: {val_kappa:.4f}\")\n        clear_output(wait=True)\n\n    print(f\"Mean Train QWK --> {np.mean(train_S):.4f}\")\n    print(f\"Mean Validation QWK ---> {np.mean(test_S):.4f}\")\n\n    KappaOPtimizer = minimize(evaluate_predictions,\n                              x0=[0.5, 1.5, 2.5], args=(y, oof_non_rounded), \n                              method='Nelder-Mead')\n    assert KappaOPtimizer.success, \"Optimization did not converge.\"\n    \n    oof_tuned = threshold_Rounder(oof_non_rounded, KappaOPtimizer.x)\n    tKappa = quadratic_weighted_kappa(y, oof_tuned)\n\n    print(f\"----> || Optimized QWK SCORE :: {Fore.CYAN}{Style.BRIGHT} {tKappa:.3f}{Style.RESET_ALL}\")\n\n    tpm = test_preds.mean(axis=1)\n    tp_rounded = threshold_Rounder(tpm, KappaOPtimizer.x)\n\n    return tp_rounded\n\nimputer = SimpleImputer(strategy='median')\n\nensemble = VotingRegressor(estimators=[\n    ('lgb', Pipeline(steps=[('imputer', imputer), ('regressor', LGBMRegressor(random_state=SEED))])),\n    ('xgb', Pipeline(steps=[('imputer', imputer), ('regressor', XGBRegressor(random_state=SEED))])),\n    ('cat', Pipeline(steps=[('imputer', imputer), ('regressor', CatBoostRegressor(random_state=SEED, silent=True))])),\n    ('rf', Pipeline(steps=[('imputer', imputer), ('regressor', RandomForestRegressor(random_state=SEED))])),\n    ('gb', Pipeline(steps=[('imputer', imputer), ('regressor', GradientBoostingRegressor(random_state=SEED))]))\n])\n\nSubmission3 = TrainML(ensemble, test)\nSubmission3 = pd.DataFrame({\n    'id': sample['id'],\n    'sii': Submission3\n})\n\nSubmission3","metadata":{"trusted":true,"execution":{"iopub.status.busy":"2024-12-01T03:27:37.461282Z","iopub.execute_input":"2024-12-01T03:27:37.461682Z","iopub.status.idle":"2024-12-01T03:31:34.685168Z","shell.execute_reply.started":"2024-12-01T03:27:37.461643Z","shell.execute_reply":"2024-12-01T03:31:34.683866Z"}},"outputs":[],"execution_count":null},{"cell_type":"code","source":"sub1 = Submission1\nsub2 = Submission2\nsub3 = Submission3\n\nsub1 = sub1.sort_values(by='id').reset_index(drop=True)\nsub2 = sub2.sort_values(by='id').reset_index(drop=True)\nsub3 = sub3.sort_values(by='id').reset_index(drop=True)\n\ncombined = pd.DataFrame({\n    'id': sub1['id'],\n    'sii_1': sub1['sii'],\n    'sii_2': sub2['sii'],\n    'sii_3': sub3['sii'],\n})\n\ndef majority_vote(row):\n    return row.mode()[0]\n\ncombined['final_sii'] = combined[['sii_1', 'sii_2', 'sii_3']].apply(majority_vote, axis=1)\n\nfinal_submission = combined[['id', 'final_sii']].rename(columns={'final_sii': 'sii'})\n\nfinal_submission.to_csv('submission.csv', index=False)\n\nprint(\"Majority voting completed and saved to 'Final_Submission.csv'\")","metadata":{"trusted":true,"execution":{"iopub.status.busy":"2024-12-01T03:31:34.686773Z","iopub.execute_input":"2024-12-01T03:31:34.687139Z","iopub.status.idle":"2024-12-01T03:31:34.712196Z","shell.execute_reply.started":"2024-12-01T03:31:34.687094Z","shell.execute_reply":"2024-12-01T03:31:34.710812Z"}},"outputs":[],"execution_count":null},{"cell_type":"code","source":"final_submission","metadata":{"trusted":true,"execution":{"iopub.status.busy":"2024-12-01T03:31:34.713553Z","iopub.execute_input":"2024-12-01T03:31:34.714004Z","iopub.status.idle":"2024-12-01T03:31:34.729446Z","shell.execute_reply.started":"2024-12-01T03:31:34.713952Z","shell.execute_reply":"2024-12-01T03:31:34.727896Z"}},"outputs":[],"execution_count":null}]}