![](\"https://github.com/Lightning-AI/lightning-tutorials/raw/main/course_UvA-DL/13-contrastive-learning/simclr_data_augmentations.jpg\")
![](\"https://github.com/Lightning-AI/lightning-tutorials/raw/main/course_UvA-DL/13-contrastive-learning/crop_views.svg\")
![](\"https://github.com/Lightning-AI/lightning-tutorials/raw/main/course_UvA-DL/13-contrastive-learning/simclr_network_setup.svg\")
\n", "After we have trained our model via contrastive learning, we can deploy it on downstream tasks and see how well it performs with little data.\n", "A common setup, which also verifies whether the model has learned generalized representations, is to perform Logistic Regression on the features.\n", "In other words, we learn a single, linear layer that maps the representations to a class prediction.\n", "Since the base network $f(\\cdot)$ is not changed during the training process, the model can only perform well if the representations of $h$ describe all features that might be necessary for the task.\n", "Further, we do not have to worry too much about overfitting since we have very few parameters that are trained.\n", "Hence, we might expect that the model can perform well even with very little data.\n", "\n", "First, let's implement a simple Logistic Regression setup for which we assume that the images already have been encoded in their feature vectors.\n", "If very little data is available, it might be beneficial to dynamically encode the images during training so that we can also apply data augmentations.\n", "However, the way we implement it here is much more efficient and can be trained within a few seconds.\n", "Further, using data augmentations did not show any significant gain in this simple setup."]}, {"cell_type": "code", "execution_count": 12, "id": "f8ffe86d", "metadata": {"execution": {"iopub.execute_input": "2023-10-12T10:17:12.565913Z", "iopub.status.busy": "2023-10-12T10:17:12.564706Z", "iopub.status.idle": "2023-10-12T10:17:12.578058Z", "shell.execute_reply": "2023-10-12T10:17:12.577048Z"}, "papermill": {"duration": 0.221322, "end_time": "2023-10-12T10:17:12.579562", "exception": false, "start_time": "2023-10-12T10:17:12.358240", "status": "completed"}, "tags": []}, "outputs": [], "source": ["class LogisticRegression(L.LightningModule):\n", " def __init__(self, feature_dim, num_classes, lr, weight_decay, max_epochs=100):\n", " super().__init__()\n", " self.save_hyperparameters()\n", " # Mapping from representation h to classes\n", " self.model = nn.Linear(feature_dim, num_classes)\n", "\n", " def configure_optimizers(self):\n", " optimizer = optim.AdamW(self.parameters(), lr=self.hparams.lr, weight_decay=self.hparams.weight_decay)\n", " lr_scheduler = optim.lr_scheduler.MultiStepLR(\n", " optimizer, milestones=[int(self.hparams.max_epochs * 0.6), int(self.hparams.max_epochs * 0.8)], gamma=0.1\n", " )\n", " return [optimizer], [lr_scheduler]\n", "\n", " def _calculate_loss(self, batch, mode=\"train\"):\n", " feats, labels = batch\n", " preds = self.model(feats)\n", " loss = F.cross_entropy(preds, labels)\n", " acc = (preds.argmax(dim=-1) == labels).float().mean()\n", "\n", " self.log(mode + \"_loss\", loss)\n", " self.log(mode + \"_acc\", acc)\n", " return loss\n", "\n", " def training_step(self, batch, batch_idx):\n", " return self._calculate_loss(batch, mode=\"train\")\n", "\n", " def validation_step(self, batch, batch_idx):\n", " self._calculate_loss(batch, mode=\"val\")\n", "\n", " def test_step(self, batch, batch_idx):\n", " self._calculate_loss(batch, mode=\"test\")"]}, {"cell_type": "markdown", "id": "1e1f5b1a", "metadata": {"papermill": {"duration": 0.204001, "end_time": "2023-10-12T10:17:12.987596", "exception": false, "start_time": "2023-10-12T10:17:12.783595", "status": "completed"}, "tags": []}, "source": ["The data we use is the training and test set of STL10.\n", "The training contains 500 images per class, while the test set has 800 images per class."]}, {"cell_type": "code", "execution_count": 13, "id": "eb045d39", "metadata": {"execution": {"iopub.execute_input": "2023-10-12T10:17:13.447161Z", "iopub.status.busy": "2023-10-12T10:17:13.446791Z", "iopub.status.idle": "2023-10-12T10:17:23.833785Z", "shell.execute_reply": "2023-10-12T10:17:23.832933Z"}, "papermill": {"duration": 10.594537, "end_time": "2023-10-12T10:17:23.836147", "exception": false, "start_time": "2023-10-12T10:17:13.241610", "status": "completed"}, "tags": []}, "outputs": [{"name": "stdout", "output_type": "stream", "text": ["Files already downloaded and verified\n"]}, {"name": "stdout", "output_type": "stream", "text": ["Files already downloaded and verified\n", "Number of training examples: 5000\n", "Number of test examples: 8000\n"]}], "source": ["img_transforms = transforms.Compose([transforms.ToTensor(), transforms.Normalize((0.5,), (0.5,))])\n", "\n", "train_img_data = STL10(root=DATASET_PATH, split=\"train\", download=True, transform=img_transforms)\n", "test_img_data = STL10(root=DATASET_PATH, split=\"test\", download=True, transform=img_transforms)\n", "\n", "print(\"Number of training examples:\", len(train_img_data))\n", "print(\"Number of test examples:\", len(test_img_data))"]}, {"cell_type": "markdown", "id": "4fe7bb53", "metadata": {"lines_to_next_cell": 2, "papermill": {"duration": 0.205395, "end_time": "2023-10-12T10:17:24.281519", "exception": false, "start_time": "2023-10-12T10:17:24.076124", "status": "completed"}, "tags": []}, "source": ["Next, we implement a small function to encode all images in our datasets.\n", "The output representations are then used as inputs to the Logistic Regression model."]}, {"cell_type": "code", "execution_count": 14, "id": "dc036f86", "metadata": {"execution": {"iopub.execute_input": "2023-10-12T10:17:24.736492Z", "iopub.status.busy": "2023-10-12T10:17:24.736218Z", "iopub.status.idle": "2023-10-12T10:17:24.742830Z", "shell.execute_reply": "2023-10-12T10:17:24.741901Z"}, "papermill": {"duration": 0.25953, "end_time": "2023-10-12T10:17:24.744198", "exception": false, "start_time": "2023-10-12T10:17:24.484668", "status": "completed"}, "tags": []}, "outputs": [], "source": ["@torch.no_grad()\n", "def prepare_data_features(model, dataset):\n", " # Prepare model\n", " network = deepcopy(model.convnet)\n", " network.fc = nn.Identity() # Removing projection head g(.)\n", " network.eval()\n", " network.to(device)\n", "\n", " # Encode all images\n", " data_loader = data.DataLoader(dataset, batch_size=64, num_workers=NUM_WORKERS, shuffle=False, drop_last=False)\n", " feats, labels = [], []\n", " for batch_imgs, batch_labels in tqdm(data_loader):\n", " batch_imgs = batch_imgs.to(device)\n", " batch_feats = network(batch_imgs)\n", " feats.append(batch_feats.detach().cpu())\n", " labels.append(batch_labels)\n", "\n", " feats = torch.cat(feats, dim=0)\n", " labels = torch.cat(labels, dim=0)\n", "\n", " # Sort images by labels\n", " labels, idxs = labels.sort()\n", " feats = feats[idxs]\n", "\n", " return data.TensorDataset(feats, labels)"]}, {"cell_type": "markdown", "id": "0a26b004", "metadata": {"papermill": {"duration": 0.20344, "end_time": "2023-10-12T10:17:25.155830", "exception": false, "start_time": "2023-10-12T10:17:24.952390", "status": "completed"}, "tags": []}, "source": ["Let's apply the function to both training and test set below."]}, {"cell_type": "code", "execution_count": 15, "id": "9ca7aab2", "metadata": {"execution": {"iopub.execute_input": "2023-10-12T10:17:25.561965Z", "iopub.status.busy": "2023-10-12T10:17:25.561595Z", "iopub.status.idle": "2023-10-12T10:17:35.815529Z", "shell.execute_reply": "2023-10-12T10:17:35.814477Z"}, "papermill": {"duration": 10.458895, "end_time": "2023-10-12T10:17:35.817068", "exception": false, "start_time": "2023-10-12T10:17:25.358173", "status": "completed"}, "tags": []}, "outputs": [{"data": {"application/vnd.jupyter.widget-view+json": {"model_id": "942fd9f1824a4bee8a771e6388f6a097", "version_major": 2, "version_minor": 0}, "text/plain": [" 0%| | 0/79 [00:00\n", "\n", "\n"], "text/plain": ["