Untitled2.1.09.21.ipynb

{
  "nbformat": 4,
  "nbformat_minor": 0,
  "metadata": {
    "colab": {
      "name": "Untitled2.ipynb",
      "provenance": [],
      "collapsed_sections": [],
      "authorship_tag": "ABX9TyN9dt2+dyGHW1NEmEHwjvQ4",
      "include_colab_link": true
    },
    "kernelspec": {
      "name": "python3",
      "display_name": "Python 3"
    },
    "language_info": {
      "name": "python"
    }
  },
  "cells": [
    {
      "cell_type": "markdown",
      "metadata": {
        "id": "view-in-github",
        "colab_type": "text"
      },
      "source": [
        "<a href=\"https://colab.research.google.com/github/busranurorhan/Complete-Python-3-Bootcamp/blob/master/Untitled2.1.09.21.ipynb\" target=\"_parent\"><img src=\"https://colab.research.google.com/assets/colab-badge.svg\" alt=\"Open In Colab\"/></a>"
      ]
    },
    {
      "cell_type": "code",
      "metadata": {
        "id": "p8naOQtFaNNk",
        "colab": {
          "base_uri": "https://localhost:8080/"
        },
        "outputId": "432c808f-e9f2-481d-ee10-660bc495608f"
      },
      "source": [
        "!apt-get update\n",
        "!apt-get install openjdk-8-jdk-headless -qq > /dev/null\n",
        "import os\n",
        "os.environ[\"JAVA_HOME\"] = \"/usr/lib/jvm/java-8-openjdk-amd64\"\n",
        "!update-alternatives --set java /usr/lib/jvm/java-8-openjdk-amd64/jre/bin/java\n",
        "!java -version\n",
        "!pip install pyspark\n"
      ],
      "execution_count": 9,
      "outputs": [
        {
          "output_type": "stream",
          "text": [
            "\r0% [Working]\r            \rGet:1 https://cloud.r-project.org/bin/linux/ubuntu bionic-cran40/ InRelease [3,626 B]\n",
            "Ign:2 https://developer.download.nvidia.com/compute/cuda/repos/ubuntu1804/x86_64  InRelease\n",
            "Ign:3 https://developer.download.nvidia.com/compute/machine-learning/repos/ubuntu1804/x86_64  InRelease\n",
            "Hit:4 https://developer.download.nvidia.com/compute/cuda/repos/ubuntu1804/x86_64  Release\n",
            "Hit:5 https://developer.download.nvidia.com/compute/machine-learning/repos/ubuntu1804/x86_64  Release\n",
            "Get:6 http://security.ubuntu.com/ubuntu bionic-security InRelease [88.7 kB]\n",
            "Hit:7 http://archive.ubuntu.com/ubuntu bionic InRelease\n",
            "Get:8 https://cloud.r-project.org/bin/linux/ubuntu bionic-cran40/ Packages [67.0 kB]\n",
            "Get:9 http://archive.ubuntu.com/ubuntu bionic-updates InRelease [88.7 kB]\n",
            "Get:12 http://archive.ubuntu.com/ubuntu bionic-backports InRelease [74.6 kB]\n",
            "Hit:13 http://ppa.launchpad.net/c2d4u.team/c2d4u4.0+/ubuntu bionic InRelease\n",
            "Get:14 http://security.ubuntu.com/ubuntu bionic-security/universe amd64 Packages [1,426 kB]\n",
            "Get:15 http://archive.ubuntu.com/ubuntu bionic-updates/universe amd64 Packages [2,200 kB]\n",
            "Get:16 http://security.ubuntu.com/ubuntu bionic-security/main amd64 Packages [2,295 kB]\n",
            "Get:17 http://archive.ubuntu.com/ubuntu bionic-updates/main amd64 Packages [2,731 kB]\n",
            "Hit:18 http://ppa.launchpad.net/cran/libgit2/ubuntu bionic InRelease\n",
            "Hit:19 http://ppa.launchpad.net/deadsnakes/ppa/ubuntu bionic InRelease\n",
            "Get:20 http://ppa.launchpad.net/graphics-drivers/ppa/ubuntu bionic InRelease [21.3 kB]\n",
            "Get:21 http://ppa.launchpad.net/graphics-drivers/ppa/ubuntu bionic/main amd64 Packages [41.6 kB]\n",
            "Fetched 9,038 kB in 7s (1,340 kB/s)\n",
            "Reading package lists... Done\n",
            "update-alternatives: using /usr/lib/jvm/java-8-openjdk-amd64/jre/bin/java to provide /usr/bin/java (java) in manual mode\n",
            "openjdk version \"1.8.0_292\"\n",
            "OpenJDK Runtime Environment (build 1.8.0_292-8u292-b10-0ubuntu1~18.04-b10)\n",
            "OpenJDK 64-Bit Server VM (build 25.292-b10, mixed mode)\n",
            "Collecting pyspark\n",
            "  Downloading pyspark-3.1.2.tar.gz (212.4 MB)\n",
            "\u001b[K     |████████████████████████████████| 212.4 MB 67 kB/s \n",
            "\u001b[?25hCollecting py4j==0.10.9\n",
            "  Downloading py4j-0.10.9-py2.py3-none-any.whl (198 kB)\n",
            "\u001b[K     |████████████████████████████████| 198 kB 48.0 MB/s \n",
            "\u001b[?25hBuilding wheels for collected packages: pyspark\n",
            "  Building wheel for pyspark (setup.py) ... \u001b[?25l\u001b[?25hdone\n",
            "  Created wheel for pyspark: filename=pyspark-3.1.2-py2.py3-none-any.whl size=212880768 sha256=dd8f1170890c45d92d96d95e797cc804ed55791651785ae70caaa3467bbf702f\n",
            "  Stored in directory: /root/.cache/pip/wheels/a5/0a/c1/9561f6fecb759579a7d863dcd846daaa95f598744e71b02c77\n",
            "Successfully built pyspark\n",
            "Installing collected packages: py4j, pyspark\n",
            "Successfully installed py4j-0.10.9 pyspark-3.1.2\n"
          ],
          "name": "stdout"
        }
      ]
    },
    {
      "cell_type": "code",
      "metadata": {
        "colab": {
          "base_uri": "https://localhost:8080/",
          "height": 191
        },
        "id": "3usnS2KqxiAQ",
        "outputId": "56f679a9-cbe2-41d3-d753-babbd901fa30"
      },
      "source": [
        "from pyspark import SparkContext\n",
        "sc = SparkContext.getOrCreate()\n",
        "sc"
      ],
      "execution_count": 10,
      "outputs": [
        {
          "output_type": "execute_result",
          "data": {
            "text/html": [
              "\n",
              "        <div>\n",
              "            <p><b>SparkContext</b></p>\n",
              "\n",
              "            <p><a href=\"http://285ffc98e998:4040\">Spark UI</a></p>\n",
              "\n",
              "            <dl>\n",
              "              <dt>Version</dt>\n",
              "                <dd><code>v3.1.2</code></dd>\n",
              "              <dt>Master</dt>\n",
              "                <dd><code>local[*]</code></dd>\n",
              "              <dt>AppName</dt>\n",
              "                <dd><code>pyspark-shell</code></dd>\n",
              "            </dl>\n",
              "        </div>\n",
              "        "
            ],
            "text/plain": [
              "<SparkContext master=local[*] appName=pyspark-shell>"
            ]
          },
          "metadata": {},
          "execution_count": 10
        }
      ]
    },
    {
      "cell_type": "code",
      "metadata": {
        "colab": {
          "base_uri": "https://localhost:8080/"
        },
        "id": "XcHdCCSjxqxk",
        "outputId": "2cedf2a3-f22d-4845-d1b5-a337a3be83eb"
      },
      "source": [
        "pointsRDD = sc.textFile(\"points.txt\")\n",
        "def splitAndConvert(satir):\n",
        "  arr = satir.split(',')\n",
        "  x = int( arr[0] )\n",
        "  y = int( arr[1] )\n",
        "  return (x,y)\n",
        "pointsRDD = pointsRDD.map(lambda line : splitAndConvert(line))\n",
        "pointsRDD = pointsRDD.map(lambda a : (a[0],a[1],a[0]+a[1]) )\n",
        "\n",
        "pointsRDD = pointsRDD.filter(lambda c : c[2]<20)\n",
        "pointsRDD.collect()"
      ],
      "execution_count": 22,
      "outputs": [
        {
          "output_type": "execute_result",
          "data": {
            "text/plain": [
              "[(5, 5, 10),\n",
              " (5, 6, 11),\n",
              " (6, 6, 12),\n",
              " (8, 8, 16),\n",
              " (7, 6, 13),\n",
              " (6, 7, 13),\n",
              " (7, 8, 15),\n",
              " (8, 6, 14),\n",
              " (5, 8, 13),\n",
              " (8, 8, 16),\n",
              " (6, 7, 13),\n",
              " (7, 8, 15)]"
            ]
          },
          "metadata": {},
          "execution_count": 22
        }
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {
        "id": "lB30gyokyhNx"
      },
      "source": [
        "# New Section"
      ]
    },
    {
      "cell_type": "code",
      "metadata": {
        "colab": {
          "base_uri": "https://localhost:8080/"
        },
        "id": "Tmu8hY2RyBsA",
        "outputId": "ef74e5f5-834d-4ba0-d1f4-0461c4f421fb"
      },
      "source": [
        "textRDD = sc.textFile('text.txt')\n",
        "textRDD = textRDD.flatMap(lambda line : line.split(' '))\n",
        "textRDD = textRDD.filter(lambda kelime : len(kelime)>0)\n",
        "textRDD.collect()"
      ],
      "execution_count": 21,
      "outputs": [
        {
          "output_type": "execute_result",
          "data": {
            "text/plain": [
              "['�Gelece�in',\n",
              " 'G�c��',\n",
              " 'ba�l�kl�',\n",
              " 'yaz�',\n",
              " 'dizimizde',\n",
              " 'Sabanc�',\n",
              " '�niversitesi�nin',\n",
              " 'profesyonellere',\n",
              " 'y�nelik',\n",
              " 'sundu�u',\n",
              " 'tezsiz',\n",
              " 'y�ksek',\n",
              " 'lisans',\n",
              " 'programlar�n�',\n",
              " 'tan�may�',\n",
              " 's�rd�r�yoruz.',\n",
              " 'Bili�im',\n",
              " 'Teknolojileri',\n",
              " 'Tezsiz',\n",
              " 'Y�ksek',\n",
              " 'Lisans',\n",
              " 'Program�m�z�n',\n",
              " 'Akademik',\n",
              " 'Direkt�r�',\n",
              " 'H.',\n",
              " 'Sait',\n",
              " '�lmez',\n",
              " 'ile',\n",
              " 'program�n',\n",
              " 'sundu�u',\n",
              " 'imkanlar�',\n",
              " 'konu�tuk.',\n",
              " 'Programla',\n",
              " 'ilgili',\n",
              " 'biraz',\n",
              " 'bilgi',\n",
              " 'verebilir',\n",
              " 'misiniz?',\n",
              " 'Ne',\n",
              " 'zaman',\n",
              " 'a��ld�?',\n",
              " '�zellikle',\n",
              " 'kimlere',\n",
              " 'hitap',\n",
              " 'ediyor?',\n",
              " '2002',\n",
              " 'y�l�nda',\n",
              " 'a��lan',\n",
              " 'program�m�z,',\n",
              " 'bili�im',\n",
              " 'teknolojilerindeki',\n",
              " 'yeti�mi�',\n",
              " 'eleman',\n",
              " 'a����na',\n",
              " 'cevap',\n",
              " 'vermek',\n",
              " '�zere',\n",
              " 've',\n",
              " 'tamamen',\n",
              " 'bu',\n",
              " 'konudaki',\n",
              " 'end�stri',\n",
              " 'ihtiya�lar�',\n",
              " 'referans',\n",
              " 'al�narak',\n",
              " 'tasarland�.',\n",
              " 'Program,',\n",
              " 'ana',\n",
              " 'hedefi',\n",
              " 'yaz�l�m',\n",
              " 'geli�tirici',\n",
              " '(software',\n",
              " 'developer)',\n",
              " 'yeti�tirmektir.',\n",
              " 'Ancak',\n",
              " 'e�itim',\n",
              " 'program�ndaki',\n",
              " 'se�meli',\n",
              " 'derslerin',\n",
              " 'zenginli�i',\n",
              " 'kat�l�mc�lara',\n",
              " 'yaz�l�m',\n",
              " 's�nama,',\n",
              " 'a�',\n",
              " 'tasar�m',\n",
              " 've',\n",
              " 'g�venli�i,',\n",
              " 'veri',\n",
              " 'taban�',\n",
              " 'uygulamalar�,',\n",
              " 'ara',\n",
              " 'y�z',\n",
              " '(UX)',\n",
              " 'tasar�m�',\n",
              " 've',\n",
              " 'veri',\n",
              " 'bilimi',\n",
              " 'gibi',\n",
              " 'konularda',\n",
              " 'da',\n",
              " 'uzmanl�k',\n",
              " 'f�rsat�',\n",
              " 'tan�maktad�r.',\n",
              " 'Program',\n",
              " 'i�erikleri',\n",
              " 'nas�l',\n",
              " 'belirleniyor,',\n",
              " 'her',\n",
              " 'y�l',\n",
              " 'de�i�iklik',\n",
              " 'yap�l�yor',\n",
              " 'mu?',\n",
              " 'Akademik',\n",
              " 'y�l',\n",
              " 'ba�lamadan',\n",
              " '�nce',\n",
              " 'program',\n",
              " 'kurulu',\n",
              " 'yaz�l�m',\n",
              " 've',\n",
              " 'IT',\n",
              " 'end�strisindeki',\n",
              " 'trendleri,',\n",
              " 'geli�meleri',\n",
              " 've',\n",
              " 'yak�n',\n",
              " 'zamanda',\n",
              " 'istihdam',\n",
              " 'ihtiyac�',\n",
              " 'ortaya',\n",
              " '��kmas�',\n",
              " 'beklenen',\n",
              " 'alanlar�',\n",
              " 'de�erlendirerek',\n",
              " 'ya',\n",
              " 'm�fredata',\n",
              " 'yeni',\n",
              " 'dersler',\n",
              " 'ekliyor',\n",
              " 'ya',\n",
              " 'da',\n",
              " 'mevcut',\n",
              " 'derslerin',\n",
              " 'i�erik',\n",
              " 've',\n",
              " 'kapsamlar�nda',\n",
              " 'revizyonlar',\n",
              " 'ger�ekle�tiriyor.',\n",
              " 'Program',\n",
              " 'sekt�r�n',\n",
              " '�zellikle',\n",
              " 'hangi',\n",
              " 'ihtiyac�na',\n",
              " 'yan�t',\n",
              " 'veriyor?',\n",
              " 'Bu',\n",
              " 'kapsamda',\n",
              " 'gelecekte',\n",
              " 'en',\n",
              " '�ok',\n",
              " 'ihtiya�',\n",
              " 'duyulacak',\n",
              " 'yetkinlikleri',\n",
              " 've',\n",
              " 'bunu',\n",
              " 'kar��lamak',\n",
              " '�zere',\n",
              " 'neler',\n",
              " 'yap�lmas�',\n",
              " 'gerekti�ini',\n",
              " 'anlat�r',\n",
              " 'm�s�n�z?',\n",
              " 'Program,',\n",
              " 'her',\n",
              " 't�r',\n",
              " 'end�stride',\n",
              " 't�m',\n",
              " 'kurumlar�n',\n",
              " 'yaz�l�m',\n",
              " 'geli�tirme,',\n",
              " 'i�',\n",
              " 'analizi,',\n",
              " 'yaz�l�m',\n",
              " 's�nama,',\n",
              " 'a�',\n",
              " 'tasar�m�',\n",
              " 've',\n",
              " 'g�venli�i,',\n",
              " 'veri',\n",
              " 'taban�',\n",
              " 'uygulamalar�',\n",
              " 'gibi',\n",
              " 'alanlarda',\n",
              " 'IT',\n",
              " 'operasyonlar�n�',\n",
              " 'y�r�tmek',\n",
              " '�zere',\n",
              " 'ihtiya�',\n",
              " 'duydu�u',\n",
              " 'mesleki',\n",
              " 'profilleri',\n",
              " 'kat�l�mc�lar�na',\n",
              " 'kazand�rmaya',\n",
              " '�al���yor.',\n",
              " 'Mezunlar�n�zla',\n",
              " 'ilgili',\n",
              " 'bilgi',\n",
              " 'verir',\n",
              " 'misiniz?',\n",
              " 'Program�',\n",
              " 'bitiren',\n",
              " '��rencilerinizin',\n",
              " 'kariyerlerinde',\n",
              " 'ne',\n",
              " 'gibi',\n",
              " 'farkl�l�klar',\n",
              " 'oluyor?',\n",
              " 'BT',\n",
              " 'Program�',\n",
              " 'mezunlar�n�n',\n",
              " 'bir',\n",
              " '�o�unlu�u',\n",
              " 'hi�bir',\n",
              " 'programlama',\n",
              " 'dili',\n",
              " 'bilmedikleri',\n",
              " 'halde',\n",
              " 'programa',\n",
              " 'kay�t',\n",
              " 'olup',\n",
              " 'hen�z',\n",
              " 'e�itimleri',\n",
              " 'tamamlanmadan',\n",
              " 'T�rkiye�nin',\n",
              " 'kendi',\n",
              " 'end�strisinde',\n",
              " 'bilinen',\n",
              " 'kurumlar�nda',\n",
              " 'yaz�l�m',\n",
              " 'geli�tirici',\n",
              " 'olarak',\n",
              " 'i�',\n",
              " 'bulabiliyorlar.',\n",
              " '2002�den',\n",
              " 'bu',\n",
              " 'yana',\n",
              " 'e�itim',\n",
              " 'veren',\n",
              " 'bu',\n",
              " 'y�ksek',\n",
              " 'lisans',\n",
              " 'program�nda',\n",
              " 'en',\n",
              " 's�k',\n",
              " 've',\n",
              " 'memnuniyetle',\n",
              " 'g�zlemledi�imiz',\n",
              " 'sonu�lardan',\n",
              " 'birisi',\n",
              " 'bu.',\n",
              " 'msit.sabanciuniv.edu',\n",
              " 'sayfam�zdan',\n",
              " 'mezun',\n",
              " 'g�r��lerinde',\n",
              " 'buna',\n",
              " 's�yledi�im',\n",
              " 't�rde',\n",
              " '�rneklerin',\n",
              " 'bir',\n",
              " 'k�sm�n�',\n",
              " 've',\n",
              " 'genel',\n",
              " 'olarak',\n",
              " 'kat�l�mc�lar�n',\n",
              " 'programla',\n",
              " 'ilgili',\n",
              " 'd���ncelerini',\n",
              " 'inceleyebilirsiniz.']"
            ]
          },
          "metadata": {},
          "execution_count": 21
        }
      ]
    },
    {
      "cell_type": "code",
      "metadata": {
        "colab": {
          "base_uri": "https://localhost:8080/"
        },
        "id": "V1EuKuXj715F",
        "outputId": "3cf96f0c-e4cc-45c5-aece-b9488e166813"
      },
      "source": [
        "from pyspark import SparkContext\n",
        "sc = SparkContext.getOrCreate()\n",
        "depremRDD = sc.textFile(\"DepremVerileri.txt\")\n",
        "depremRDD = depremRDD.filter(lambda line : \"Deprem Kodu\" not in line)\n",
        "def splitAndTake(line):\n",
        "  arr = line.split(\"\\t\")\n",
        "  enlem = float(arr[4])\n",
        "  boylam = float(arr[5])\n",
        "  buyukluk = float(arr[7])\n",
        "  yer = arr[14]\n",
        "  tarih = arr[2]\n",
        "\n",
        "  return(tarih,enlem,boylam,buyukluk,yer)\n",
        "\n",
        "depremRDD = depremRDD.map(lambda a : splitAndTake(a))\n",
        "depremRDD = depremRDD.sortBy(lambda b : b[3],ascending=False)\n",
        "\n",
        "for d in depremRDD.take(20):\n",
        "    print(d)"
      ],
      "execution_count": 30,
      "outputs": [
        {
          "output_type": "stream",
          "text": [
            "('1939.12.26', 39.8, 39.51, 7.9, 'KURUTILEK- (ERZINCAN) [North East  3.0 km]')\n",
            "('1926.06.26', 36.54, 27.33, 7.7, 'ONIKI ADALAR (AKDENIZ)')\n",
            "('1930.05.06', 37.98, 44.48, 7.6, 'T�RKIYE-IRAN SINIR B�LGESI')\n",
            "('1976.11.24', 39.05, 44.04, 7.5, 'YENIYAKA-CALDIRAN (VAN) [South East  1.9 km]')\n",
            "('1999.08.17', 40.76, 29.97, 7.4, 'BASISKELE (KOCAELI) [North East  2.0 km]')\n",
            "('1912.08.09', 40.6, 27.2, 7.3, 'ERIKLICE-SARKOY (TEKIRDAG) [South East  4.3 km]')\n",
            "('2011.10.23', 38.7212, 43.411, 7.2, 'YEMLICE- (VAN) [North West  1.5 km]')\n",
            "('1999.11.12', 40.74, 31.21, 7.2, 'UGUR- (DUZCE) [North East  0.3 km]')\n",
            "('1953.03.18', 39.99, 27.36, 7.2, 'SOGUCAK-YENICE (�ANAKKALE) [South West  2.3 km]')\n",
            "('1948.02.09', 35.41, 27.2, 7.2, 'AKDENIZ')\n",
            "('1944.02.01', 40.7871, 31.8723, 7.2, 'ULUMESCIT-(BOLU)')\n",
            "('1943.11.26', 41.05, 33.72, 7.2, 'COMERT-ILGAZ (�ANKIRI) [North West  2.2 km]')\n",
            "('1957.05.26', 40.67, 31.0, 7.1, 'GUZELDERE-GOLYAKA (DUZCE) [South West  7.1 km]')\n",
            "('1957.04.25', 36.42, 28.68, 7.1, 'AKDENIZ')\n",
            "('1916.01.24', 40.27, 36.83, 7.1, 'TEKNECIK-ALMUS (TOKAT) [South West  0.6 km]')\n",
            "('1970.03.28', 39.21, 29.51, 7.0, 'KIZIK-CAVDARHISAR (K�TAHYA) [North 0.8 km]')\n",
            "('1964.10.06', 40.3, 28.23, 7.0, 'OKCULAR-KARACABEY (BURSA) [North East  1.5 km]')\n",
            "('1942.12.20', 40.87, 36.47, 7.0, 'ERDEMLI-ERBAA (TOKAT) [North West  2.8 km]')\n",
            "('1919.11.18', 39.26, 26.71, 7.0, 'KUCUKKOY-AYVALIK (BALIKESIR) [South East  3.6 km]')\n",
            "('2020.10.30', 37.8877, 26.7057, 6.9, 'EGE DENIZI')\n"
          ],
          "name": "stdout"
        }
      ]
    },
    {
      "cell_type": "code",
      "metadata": {
        "colab": {
          "base_uri": "https://localhost:8080/"
        },
        "id": "eIDBvZ6A_52h",
        "outputId": "280fb4d3-895f-442a-8e07-8e6bdef814b2"
      },
      "source": [
        "from pyspark import SparkContext\n",
        "sc = SparkContext.getOrCreate()\n",
        "depremRDD = sc.textFile(\"DepremVerileri.txt\")\n",
        "depremRDD = depremRDD.filter(lambda line : \"Deprem Kodu\" not in line)\n",
        "def splitAndTake(line):\n",
        "  arr = line.split(\"\\t\")\n",
        "  enlem = float(arr[4])\n",
        "  boylam = float(arr[5])\n",
        "  buyukluk = float(arr[7])\n",
        "  yer = arr[14]\n",
        "  tarih = arr[2]\n",
        "\n",
        "  return(tarih,enlem,boylam,buyukluk,yer)\n",
        "\n",
        "depremRDD = depremRDD.map(lambda a : splitAndTake(a))\n",
        "depremRDD = depremRDD.sortBy(lambda b : b[3] > 3.5)\n",
        "for d in depremRDD.take(10):\n",
        "  print(d)"
      ],
      "execution_count": 33,
      "outputs": [
        {
          "output_type": "stream",
          "text": [
            "('2021.04.27', 36.4623, 27.0743, 3.5, 'ONIKI ADALAR (AKDENIZ)')\n",
            "('2021.04.26', 36.468, 27.1527, 3.5, 'ONIKI ADALAR (AKDENIZ)')\n",
            "('2021.04.25', 36.3965, 27.0443, 3.5, 'AKDENIZ')\n",
            "('2021.04.25', 36.4478, 27.1165, 3.5, 'ONIKI ADALAR (AKDENIZ)')\n",
            "('2021.04.23', 38.2892, 38.8912, 3.5, 'TATLICAK-PUTURGE (MALATYA) [North 1.0 km]')\n",
            "('2021.04.22', 36.3988, 27.1045, 3.5, 'ONIKI ADALAR (AKDENIZ)')\n",
            "('2021.04.21', 38.2692, 38.8238, 3.5, 'AKTARLI-PUTURGE (MALATYA) [South East  0.7 km]')\n",
            "('2021.04.20', 38.6437, 43.7055, 3.5, 'KAYMAKLI- (VAN) [North East  0.7 km]')\n",
            "('2021.04.20', 36.43, 27.0643, 3.5, 'ONIKI ADALAR (AKDENIZ)')\n",
            "('2021.04.18', 36.4355, 27.1325, 3.5, 'ONIKI ADALAR (AKDENIZ)')\n"
          ],
          "name": "stdout"
        }
      ]
    },
    {
      "cell_type": "code",
      "metadata": {
        "colab": {
          "base_uri": "https://localhost:8080/"
        },
        "id": "Dpu5bQfkHpYA",
        "outputId": "b2875107-3b78-4553-9a74-c8ebe3a895a9"
      },
      "source": [
        "from pyspark import SparkContext\n",
        "sc = SparkContext.getOrCreate()\n",
        "depremRDD = sc.textFile('DepremVerileri.txt')\n",
        "depremRDD = depremRDD.filter(lambda line : 'Deprem Kodu' not in line)\n",
        "def splitAndTake(line):\n",
        "  arr = line.split(\"\\t\")\n",
        "  enlem = float(arr[4])\n",
        "  boylam = float(arr[5])\n",
        "  buyukluk = float(arr[7])\n",
        "  yer = arr[14]\n",
        "  tarih = arr[2]\n",
        "  return(enlem,boylam)\n",
        "\n",
        "depremRDD = depremRDD.map(lambda a: splitAndTake(a))\n",
        "\n",
        "\n",
        "depremRDD.take(15)"
      ],
      "execution_count": 65,
      "outputs": [
        {
          "output_type": "execute_result",
          "data": {
            "text/plain": [
              "[(36.5977, 31.6742),\n",
              " (36.4623, 27.0743),\n",
              " (36.4148, 27.1748),\n",
              " (36.4537, 27.1223),\n",
              " (37.818, 26.9463),\n",
              " (36.468, 27.1527),\n",
              " (36.4157, 27.1588),\n",
              " (35.19, 27.6978),\n",
              " (36.3965, 27.0443),\n",
              " (38.2125, 42.5825),\n",
              " (38.1922, 42.5515),\n",
              " (36.4478, 27.1165),\n",
              " (37.917, 27.229),\n",
              " (35.5523, 27.4485),\n",
              " (36.4577, 27.1567)]"
            ]
          },
          "metadata": {},
          "execution_count": 65
        }
      ]
    },
    {
      "cell_type": "code",
      "metadata": {
        "id": "GEdlT8DuSGqq"
      },
      "source": [
        ""
      ],
      "execution_count": null,
      "outputs": []
    },
    {
      "cell_type": "code",
      "metadata": {
        "colab": {
          "base_uri": "https://localhost:8080/"
        },
        "id": "GMvDgUIfSQZ2",
        "outputId": "6a630bb2-9166-4861-854b-a970aa04a142"
      },
      "source": [
        "s = sc.parallelize([1,2,3,4,5,6,7,8])\n",
        "toplam = s.reduce(lambda x,y : x+y)\n",
        "print(toplam)"
      ],
      "execution_count": 46,
      "outputs": [
        {
          "output_type": "stream",
          "text": [
            "36\n"
          ],
          "name": "stdout"
        }
      ]
    },
    {
      "cell_type": "code",
      "metadata": {
        "colab": {
          "base_uri": "https://localhost:8080/"
        },
        "id": "HCBPxAjuSYVq",
        "outputId": "a2fcc2e6-883c-4907-d3ff-118c4e7122ed"
      },
      "source": [
        "rdd1 = sc.parallelize([(\"a\",1),(\"b\",8),(\"c\",2),(\"a\",4),(\"c\",3)])\n",
        "rdd2 = sc.parallelize([(\"a\",4),(\"b\",5),(\"e\",1),(\"f\",4),(\"b\",2)])\n",
        "rdd3 = rdd1.union(rdd2)\n",
        "print(rdd3.collect())"
      ],
      "execution_count": 48,
      "outputs": [
        {
          "output_type": "stream",
          "text": [
            "[('a', 1), ('b', 8), ('c', 2), ('a', 4), ('c', 3), ('a', 4), ('b', 5), ('e', 1), ('f', 4), ('b', 2)]\n"
          ],
          "name": "stdout"
        }
      ]
    },
    {
      "cell_type": "code",
      "metadata": {
        "colab": {
          "base_uri": "https://localhost:8080/"
        },
        "id": "KHcdBZUkSldl",
        "outputId": "92f45141-aac2-4130-b950-9be24b6c46e6"
      },
      "source": [
        "rdd4 = rdd1.join(rdd2)\n",
        "print(rdd4.collect())"
      ],
      "execution_count": 49,
      "outputs": [
        {
          "output_type": "stream",
          "text": [
            "[('b', (8, 5)), ('b', (8, 2)), ('a', (1, 4)), ('a', (4, 4))]\n"
          ],
          "name": "stdout"
        }
      ]
    },
    {
      "cell_type": "code",
      "metadata": {
        "colab": {
          "base_uri": "https://localhost:8080/"
        },
        "id": "ysdIvmMqS-1s",
        "outputId": "fe9647c3-310a-4d5f-86ed-4b81f09b4231"
      },
      "source": [
        "rdd1 = sc.parallelize([(\"a\",1),(\"b\",8),(\"c\",2),(\"a\",4),(\"c\",3)])\n",
        "groupRDD = rdd1.groupByKey().map(lambda x : (x[0],tuple(x[1])))\n",
        "#groupRDD = rdd1.groupByKey()\n",
        "groupRDD.collect()\n",
        "\n"
      ],
      "execution_count": 50,
      "outputs": [
        {
          "output_type": "execute_result",
          "data": {
            "text/plain": [
              "[('b', (8,)), ('c', (2, 3)), ('a', (1, 4))]"
            ]
          },
          "metadata": {},
          "execution_count": 50
        }
      ]
    },
    {
      "cell_type": "code",
      "metadata": {
        "colab": {
          "base_uri": "https://localhost:8080/"
        },
        "id": "Y8s72GSwUvPp",
        "outputId": "9e6289d5-d78b-4936-9557-2bde5760215c"
      },
      "source": [
        "rdd1 = sc.parallelize([(\"a\",1),(\"b\",8),(\"c\",2),(\"a\",4),(\"c\",3)])\n",
        "rdd2 = sc.parallelize([(\"a\",4),(\"b\",5),(\"e\",1),(\"f\",4),(\"b\",2)])\n",
        "\n",
        "rdd5 = rdd1.cartesian(rdd2)\n",
        "rdd5.collect()\n",
        "#rdd5.sortBy(lambda x: x[0][0]).collect()"
      ],
      "execution_count": 51,
      "outputs": [
        {
          "output_type": "execute_result",
          "data": {
            "text/plain": [
              "[(('a', 1), ('a', 4)),\n",
              " (('a', 1), ('b', 5)),\n",
              " (('b', 8), ('a', 4)),\n",
              " (('b', 8), ('b', 5)),\n",
              " (('a', 1), ('e', 1)),\n",
              " (('a', 1), ('f', 4)),\n",
              " (('b', 8), ('e', 1)),\n",
              " (('b', 8), ('f', 4)),\n",
              " (('a', 1), ('b', 2)),\n",
              " (('b', 8), ('b', 2)),\n",
              " (('c', 2), ('a', 4)),\n",
              " (('c', 2), ('b', 5)),\n",
              " (('a', 4), ('a', 4)),\n",
              " (('a', 4), ('b', 5)),\n",
              " (('c', 3), ('a', 4)),\n",
              " (('c', 3), ('b', 5)),\n",
              " (('c', 2), ('e', 1)),\n",
              " (('c', 2), ('f', 4)),\n",
              " (('a', 4), ('e', 1)),\n",
              " (('a', 4), ('f', 4)),\n",
              " (('c', 2), ('b', 2)),\n",
              " (('a', 4), ('b', 2)),\n",
              " (('c', 3), ('e', 1)),\n",
              " (('c', 3), ('f', 4)),\n",
              " (('c', 3), ('b', 2))]"
            ]
          },
          "metadata": {},
          "execution_count": 51
        }
      ]
    },
    {
      "cell_type": "code",
      "metadata": {
        "colab": {
          "base_uri": "https://localhost:8080/"
        },
        "id": "mDFSOm3FWsJe",
        "outputId": "0cb9664c-a08f-4375-e5c2-62284fd670f0"
      },
      "source": [
        "rdd = sc.parallelize([ (\"09-06-2021\",123) ,(\"09-07-2021\",133) ,(\"09-08-2021\",142)])\n",
        "rdd = rdd.zipWithIndex()\n",
        "rdd = rdd.map(lambda x : (x[1],x[0]))\n",
        "rdd2 = rdd\n",
        "rdd.collect()\n",
        "rdd2 = rdd2.map(lambda b : (b[0]+1,b[1]))\n",
        "rdd3 = rdd2.join(rdd)\n",
        "rdd3.collect()"
      ],
      "execution_count": 52,
      "outputs": [
        {
          "output_type": "execute_result",
          "data": {
            "text/plain": [
              "[(1, (('09-06-2021', 123), ('09-07-2021', 133))),\n",
              " (2, (('09-07-2021', 133), ('09-08-2021', 142)))]"
            ]
          },
          "metadata": {},
          "execution_count": 52
        }
      ]
    },
    {
      "cell_type": "code",
      "metadata": {
        "colab": {
          "base_uri": "https://localhost:8080/"
        },
        "id": "mwMwpXoxpc7m",
        "outputId": "cbc760c9-d42e-4637-8d3e-0d0b71456a96"
      },
      "source": [
        "file = open(\"Capitals.txt\",\"r\")\n",
        "satirlar = file.readlines() \n",
        "#print(satirlar)\n",
        "\n",
        "ulkeler = []\n",
        "for satir in satirlar:\n",
        "    info = satir.split(\"/t\")\n",
        "    ulkeler.append(info)\n",
        "\n",
        "#print(ulkeler)\n",
        "\n",
        "def splitAndTake(line):\n",
        "  arr = satir.split(' \\t')\n",
        "  enlem = float(arr[3])\n",
        "  boylam = float(arr[4])\n",
        "  capital = arr[2]\n",
        "  ulke = arr[1]\n",
        "  \n",
        "\n",
        "  return(ulke,capital,enlem,boylam)\n",
        "\n",
        "print(ulkeler)\n",
        "\n",
        "for i in ulkeler:\n",
        "  ulkeler[]\n",
        "\n",
        "#ulkelerRDD = sc.parallelize(ulkeler) \n",
        "#ulkelerRDD = ulkelerRDD.filter(lambda a : a[3]< abs(90) )\n",
        "#ulkelerRDD = ulkelerRDD.filter(lambda b : b[4]< abs(180) )\n",
        "\n",
        "#ulkelerRDD = ulkelerRDD.map(lambda a : splitAndTake(a))\n",
        "#ulkelerRDD.collect()\n",
        "\n"
      ],
      "execution_count": 27,
      "outputs": [
        {
          "output_type": "stream",
          "text": [
            "[['Afghanistan Flag Icon \\tAfghanistan \\tKabul \\t34,53 \\t69,17\\t\\n'], ['Albania Flag Icon \\tAlbania \\tTirana \\t41,33 \\t19,82\\t\\n'], ['Algeria Flag Icon \\tAlgeria \\tAlgiers \\t36,75 \\t3,04\\t\\n'], ['American Samoa Flag Icon \\tAmerican Samoa \\tPago Pago \\t-14,28 \\t-170,70\\t\\n'], ['Andorra Flag Icon \\tAndorra \\tAndorra la Vella \\t42,51 \\t1,52\\t\\n'], ['Angola Flag Icon \\tAngola \\tLuanda \\t-8,84 \\t13,23\\t\\n'], ['Anguilla Flag Icon \\tAnguilla \\tThe Valley \\t18,22 \\t-63,06\\t\\n'], [\"Antigua and Barbuda Flag Icon \\tAntigua and Barbuda \\tSt. John's \\t17,12 \\t-61,85\\t\\n\"], ['Argentina Flag Icon \\tArgentina \\tBuenos Aires \\t-34,61 \\t-58,38\\t\\n'], ['Armenia Flag Icon \\tArmenia \\tYerevan \\t40,18 \\t44,51\\t\\n'], ['Aruba Flag Icon \\tAruba \\tOranjestad \\t12,52 \\t-70,03\\t\\n'], ['Australia Flag Icon \\tAustralia \\tCanberra \\t-35,28 \\t149,13\\t\\n'], ['Austria Flag Icon \\tAustria \\tVienna \\t48,21 \\t16,37\\t\\n'], ['Azerbaijan Flag Icon \\tAzerbaijan \\tBaku \\t40,38 \\t49,89\\t\\n'], ['Bahamas Flag Icon \\tBahamas \\tNassau \\t25,06 \\t-77,34\\t\\n'], ['Bahrain Flag Icon \\tBahrain \\tManama \\t26,22 \\t50,58\\t\\n'], ['Bangladesh Flag Icon \\tBangladesh \\tDhaka \\t23,71 \\t90,41\\t\\n'], ['Barbados Flag Icon \\tBarbados \\tBridgetown \\t13,10 \\t-59,62\\t\\n'], ['Belarus Flag Icon \\tBelarus \\tMinsk \\t53,90 \\t27,57\\t\\n'], ['Belgium Flag Icon \\tBelgium \\tBrussels \\t50,85 \\t4,35\\t\\n'], ['Belize Flag Icon \\tBelize \\tBelmopan \\t17,25 \\t-88,77\\t\\n'], ['Benin Flag Icon \\tBenin \\tPorto-Novo \\t6,50 \\t2,60\\t\\n'], ['Bermuda Flag Icon \\tBermuda \\tHamilton \\t32,29 \\t-64,78\\t\\n'], ['Bhutan Flag Icon \\tBhutan \\tThimphu \\t27,47 \\t89,64\\t\\n'], ['Bolivia Flag Icon \\tBolivia \\tSucre \\t-19,03 \\t-65,26\\t\\n'], ['Bosnia and Herzegovina Flag Icon \\tBosnia and Herzegovina \\tSarajevo \\t43,85 \\t18,36\\t\\n'], ['Botswana Flag Icon \\tBotswana \\tGaborone \\t-24,65 \\t25,91\\t\\n'], ['Brazil Flag Icon \\tBrazil \\tBrasília \\t-15,78 \\t-47,93\\t\\n'], ['British Indian Ocean Territory Flag Icon \\tBritish Indian Ocean Territory \\tDiego Garcia \\t72,46 \\t7,24\\t\\n'], ['British Virgin Islands Flag Icon \\tBritish Virgin Islands \\tRoad Town \\t18,42 \\t-64,62\\t\\n'], ['Brunei Flag Icon \\tBrunei \\tBandar Seri Begawan \\t4,94 \\t114,95\\t\\n'], ['Bulgaria Flag Icon \\tBulgaria \\tSofia \\t42,70 \\t23,32\\t\\n'], ['Burkina Faso Flag Icon \\tBurkina Faso \\tOuagadougou \\t12,37 \\t-1,53\\t\\n'], ['Burundi Flag Icon \\tBurundi \\tBujumbura \\t-3,38 \\t29,36\\t\\n'], ['Cambodia Flag Icon \\tCambodia \\tPhnom Penh \\t11,56 \\t104,92\\t\\n'], ['Cameroon Flag Icon \\tCameroon \\tYaoundé \\t3,87 \\t11,52\\t\\n'], ['Canada Flag Icon \\tCanada \\tOttawa \\t45,41 \\t-75,70\\t\\n'], ['Cape Verde Flag Icon \\tCape Verde \\tPraia \\t14,93 \\t-23,51\\t\\n'], ['Cayman Islands Flag Icon \\tCayman Islands \\tGeorge Town \\t19,29 \\t-81,37\\t\\n'], ['Central African Republic Flag Icon \\tCentral African Republic \\tBangui \\t4,36 \\t18,55\\t\\n'], [\"Chad Flag Icon \\tChad \\tN'Djamena \\t12,11 \\t15,04\\t\\n\"], ['Chile Flag Icon \\tChile \\tSantiago \\t-33,46 \\t-70,65\\t\\n'], ['China Flag Icon \\tChina \\tBeijing \\t39,91 \\t116,40\\t\\n'], ['Christmas Island Flag Icon \\tChristmas Island \\tThe Settlement \\t-10,42 \\t105,68\\t\\n'], ['Cocos Islands Flag Icon \\tCocos Islands \\tWest Island \\t-12,16 \\t96,82\\t\\n'], ['Colombia Flag Icon \\tColombia \\tBogotá \\t4,61 \\t-74,08\\t\\n'], ['Comoros Flag Icon \\tComoros \\tMoroni \\t-11,70 \\t43,26\\t\\n'], ['Cook Islands Flag Icon \\tCook Islands \\tAvarua \\t-21,21 \\t-159,78\\t\\n'], ['Costa Rica Flag Icon \\tCosta Rica \\tSan José \\t9,93 \\t-84,08\\t\\n'], ['Croatia Flag Icon \\tCroatia \\tZagreb \\t45,81 \\t15,98\\t\\n'], ['Cuba Flag Icon \\tCuba \\tHavana \\t23,13 \\t-82,38\\t\\n'], ['Cyprus Flag Icon \\tCyprus \\tNicosia \\t35,17 \\t33,37\\t\\n'], ['Czech Republic Flag Icon \\tCzech Republic \\tPrague \\t50,09 \\t14,42\\t\\n'], ['Democratic Republic of the Congo Flag Icon \\tDemocratic Republic of the Congo \\tKinshasa \\t-4,32 \\t15,31\\t\\n'], ['Denmark Flag Icon \\tDenmark \\tCopenhagen \\t55,68 \\t12,57\\t\\n'], ['Djibouti Flag Icon \\tDjibouti \\tDjibouti \\t11,59 \\t43,15\\t\\n'], ['Dominica Flag Icon \\tDominica \\tRoseau \\t15,30 \\t-61,39\\t\\n'], ['Dominican Republic Flag Icon \\tDominican Republic \\tSanto Domingo \\t18,50 \\t-69,99\\t\\n'], ['East Timor Flag Icon \\tEast Timor \\tDili \\t-8,56 \\t125,57\\t\\n'], ['Ecuador Flag Icon \\tEcuador \\tQuito \\t-0,23 \\t-78,52\\t\\n'], ['Egypt Flag Icon \\tEgypt \\tCairo \\t30,06 \\t31,25\\t\\n'], ['El Salvador Flag Icon \\tEl Salvador \\tSan Salvador \\t13,69 \\t-89,19\\t\\n'], ['Equatorial Guinea Flag Icon \\tEquatorial Guinea \\tMalabo \\t3,75 \\t8,78\\t\\n'], ['Eritrea Flag Icon \\tEritrea \\tAsmara \\t15,33 \\t38,93\\t\\n'], ['Estonia Flag Icon \\tEstonia \\tTallinn \\t59,44 \\t24,75\\t\\n'], ['Ethiopia Flag Icon \\tEthiopia \\tAddis Ababa \\t9,02 \\t38,75\\t\\n'], ['Falkland Islands Flag Icon \\tFalkland Islands \\tStanley \\t-51,70 \\t-57,85\\t\\n'], ['Faroe Islands Flag Icon \\tFaroe Islands \\tTórshavn \\t62,01 \\t-6,77\\t\\n'], ['Fiji Flag Icon \\tFiji \\tSuva \\t-18,14 \\t178,44\\t\\n'], ['Finland Flag Icon \\tFinland \\tHelsinki \\t60,17 \\t24,94\\t\\n'], ['France Flag Icon \\tFrance \\tParis \\t48,85 \\t2,35\\t\\n'], ['French Guiana Flag Icon \\tFrench Guiana \\tCayenne \\t4,93 \\t-52,33\\t\\n'], ['French Polynesia Flag Icon \\tFrench Polynesia \\tPapeete \\t-17,53 \\t-149,57\\t\\n'], ['Gabon Flag Icon \\tGabon \\tLibreville \\t0,39 \\t9,45\\t\\n'], ['Gambia Flag Icon \\tGambia \\tBanjul \\t13,45 \\t-16,58\\t\\n'], ['Georgia Flag Icon \\tGeorgia \\tTbilisi \\t41,69 \\t44,83\\t\\n'], ['Germany Flag Icon \\tGermany \\tBerlin \\t52,52 \\t13,41\\t\\n'], ['Ghana Flag Icon \\tGhana \\tAccra \\t5,56 \\t-0,20\\t\\n'], ['Gibraltar Flag Icon \\tGibraltar \\tGibraltar \\t36,14 \\t-5,35\\t\\n'], ['Greece Flag Icon \\tGreece \\tAthens \\t37,98 \\t23,72\\t\\n'], ['Greenland Flag Icon \\tGreenland \\tNuuk (Godthåb) \\t64,18 \\t-51,72\\t\\n'], [\"Grenada Flag Icon \\tGrenada \\tSt. George's \\t12,06 \\t-61,75\\t\\n\"], ['Guadeloupe Flag Icon \\tGuadeloupe \\tBasse-Terre \\t16,00 \\t-61,73\\t\\n'], ['Guam Flag Icon \\tGuam \\tHagåtña \\t13,48 \\t144,75\\t\\n'], ['Guatemala Flag Icon \\tGuatemala \\tNew Guatemala \\t14,64 \\t-90,51\\t\\n'], ['Guernsey Flag Icon \\tGuernsey \\tSt Peter Port \\t49,46 \\t-2,54\\t\\n'], ['Guinea Flag Icon \\tGuinea \\tConakry \\t9,54 \\t-13,68\\t\\n'], ['Guinea-Bissau Flag Icon \\tGuinea-Bissau \\tBissau \\t11,86 \\t-15,60\\t\\n'], ['Guyana Flag Icon \\tGuyana \\tGeorgetown \\t6,80 \\t-58,16\\t\\n'], ['Haiti Flag Icon \\tHaiti \\tPort-au-Prince \\t18,54 \\t-72,34\\t\\n'], ['Honduras Flag Icon \\tHonduras \\tTegucigalpa \\t14,08 \\t-87,21\\t\\n'], ['Hong Kong Flag Icon \\tHong Kong \\tHong Kong \\t22,29 \\t114,16\\t\\n'], ['Hungary Flag Icon \\tHungary \\tBudapest \\t47,50 \\t19,04\\t\\n'], ['Iceland Flag Icon \\tIceland \\tReykjavík \\t64,14 \\t-21,90\\t\\n'], ['India Flag Icon \\tIndia \\tNew Delhi \\t28,64 \\t77,22\\t\\n'], ['Indonesia Flag Icon \\tIndonesia \\tJakarta \\t-6,21 \\t106,85\\t\\n'], ['Iran Flag Icon \\tIran \\tTehran \\t35,69 \\t51,42\\t\\n'], ['Iraq Flag Icon \\tIraq \\tBaghdad \\t33,34 \\t44,40\\t\\n'], ['Ireland Flag Icon \\tIreland \\tDublin \\t53,33 \\t-6,25\\t\\n'], ['Isle of Man Flag Icon \\tIsle of Man \\tDouglas \\t54,15 \\t-4,48\\t\\n'], ['Israel Flag Icon \\tIsrael \\tJerusalem \\t35,23 \\t31,77\\t\\n'], ['Italy Flag Icon \\tItaly \\tRome \\t41,89 \\t12,48\\t\\n'], ['Ivory Coast Flag Icon \\tIvory Coast \\tYamoussoukro \\t6,82 \\t-5,28\\t\\n'], ['Jamaica Flag Icon \\tJamaica \\tKingston \\t18,00 \\t-76,79\\t\\n'], ['Japan Flag Icon \\tJapan \\tEdo \\t35,69 \\t139,69\\t\\n'], ['Jersey Flag Icon \\tJersey \\tSaint Helier \\t49,19 \\t-2,10\\t\\n'], ['Jordan Flag Icon \\tJordan \\tAmman \\t31,96 \\t35,95\\t\\n'], ['Kazakhstan Flag Icon \\tKazakhstan \\tAstana \\t51,18 \\t71,45\\t\\n'], ['Kenya Flag Icon \\tKenya \\tNairobi \\t-1,28 \\t36,82\\t\\n'], ['Kiribati Flag Icon \\tKiribati \\tSouth Tarawa \\t1,33 \\t172,98\\t\\n'], ['Kosovo Flag Icon \\tKosovo \\tPristina \\t42,67 \\t21,17\\t\\n'], ['Kuwait Flag Icon \\tKuwait \\tKuwait City \\t29,37 \\t47,98\\t\\n'], ['Kyrgyzstan Flag Icon \\tKyrgyzstan \\tBishkek \\t42,87 \\t74,59\\t\\n'], ['Laos Flag Icon \\tLaos \\tVientiane \\t17,97 \\t102,60\\t\\n'], ['Latvia Flag Icon \\tLatvia \\tRiga \\t56,95 \\t24,11\\t\\n'], ['Lebanon Flag Icon \\tLebanon \\tBeirut \\t33,89 \\t35,49\\t\\n'], ['Lesotho Flag Icon \\tLesotho \\tMaseru \\t-29,32 \\t27,48\\t\\n'], ['Liberia Flag Icon \\tLiberia \\tMonrovia \\t6,30 \\t-10,80\\t\\n'], ['Libya Flag Icon \\tLibya \\tTripoli \\t32,88 \\t13,19\\t\\n'], ['Liechtenstein Flag Icon \\tLiechtenstein \\tVaduz \\t47,14 \\t9,52\\t\\n'], ['Lithuania Flag Icon \\tLithuania \\tVilnius \\t54,69 \\t25,28\\t\\n'], ['Luxembourg Flag Icon \\tLuxembourg \\tLuxembourg \\t49,61 \\t6,13\\t\\n'], ['Macao Flag Icon \\tMacao \\tMacao \\t22,20 \\t113,55\\t\\n'], ['Macedonia Flag Icon \\tMacedonia \\tSkopje \\t42,00 \\t21,43\\t\\n'], ['Madagascar Flag Icon \\tMadagascar \\tAntananarivo \\t-18,91 \\t47,54\\t\\n'], ['Malawi Flag Icon \\tMalawi \\tLilongwe \\t-13,97 \\t33,79\\t\\n'], ['Malaysia Flag Icon \\tMalaysia \\tKuala Lumpur \\t3,14 \\t101,69\\t\\n'], ['Maldives Flag Icon \\tMaldives \\tMalé \\t4,17 \\t73,51\\t\\n'], ['Mali Flag Icon \\tMali \\tBamako \\t12,65 \\t-8,00\\t\\n'], ['Malta Flag Icon \\tMalta \\tValletta \\t35,90 \\t14,51\\t\\n'], ['Marshall Islands Flag Icon \\tMarshall Islands \\tMajuro \\t7,09 \\t171,38\\t\\n'], ['Martinique Flag Icon \\tMartinique \\tFort-de-France \\t14,61 \\t-61,07\\t\\n'], ['Mauritania Flag Icon \\tMauritania \\tNouakchott \\t18,09 \\t-15,98\\t\\n'], ['Mauritius Flag Icon \\tMauritius \\tPort Louis \\t-20,16 \\t57,50\\t\\n'], ['Mayotte Flag Icon \\tMayotte \\tMamoutzou \\t-12,78 \\t45,23\\t\\n'], ['Mexico Flag Icon \\tMexico \\tMexico City \\t19,43 \\t-99,13\\t\\n'], ['Micronesia Flag Icon \\tMicronesia \\tPalikir \\t6,92 \\t158,16\\t\\n'], ['Moldova Flag Icon \\tMoldova \\tChişinău \\t47,01 \\t28,86\\t\\n'], ['Monaco Flag Icon \\tMonaco \\tMonaco \\t43,73 \\t7,42\\t\\n'], ['Mongolia Flag Icon \\tMongolia \\tUlan Bator \\t47,91 \\t106,88\\t\\n'], ['Montenegro Flag Icon \\tMontenegro \\tPodgorica \\t42,44 \\t19,26\\t\\n'], ['Montserrat Flag Icon \\tMontserrat \\tPlymouth \\t16,71 \\t-62,21\\t\\n'], ['Morocco Flag Icon \\tMorocco \\tRabat \\t34,01 \\t-6,83\\t\\n'], ['Mozambique Flag Icon \\tMozambique \\tMaputo \\t-25,97 \\t32,58\\t\\n'], ['Myanmar Flag Icon \\tMyanmar \\tNay Pyi Taw \\t19,75 \\t96,13\\t\\n'], ['Namibia Flag Icon \\tNamibia \\tWindhoek \\t-22,56 \\t17,08\\t\\n'], ['Nauru Flag Icon \\tNauru \\tYaren \\t166,93 \\t-0,54\\t\\n'], ['Nepal Flag Icon \\tNepal \\tKathmandu \\t27,70 \\t85,32\\t\\n'], ['Netherlands Flag Icon \\tNetherlands \\tAmsterdam \\t52,37 \\t4,89\\t\\n'], ['Netherlands Antilles Flag Icon \\tNetherlands Antilles \\tWillemstad \\t-68,92 \\t12,10\\t\\n'], ['New Caledonia Flag Icon \\tNew Caledonia \\tNoumea \\t-22,28 \\t166,46\\t\\n'], ['New Zealand Flag Icon \\tNew Zealand \\tWellington \\t-41,29 \\t174,78\\t\\n'], ['Nicaragua Flag Icon \\tNicaragua \\tManagua \\t12,13 \\t-86,25\\t\\n'], ['Niger Flag Icon \\tNiger \\tNiamey \\t13,51 \\t2,11\\t\\n'], ['Nigeria Flag Icon \\tNigeria \\tAbuja \\t9,07 \\t7,48\\t\\n'], ['Niue Flag Icon \\tNiue \\tAlofi \\t-19,06 \\t-169,92\\t\\n'], ['Norfolk Island Flag Icon \\tNorfolk Island \\tKingston \\t-29,05 \\t167,97\\t\\n'], ['North Korea Flag Icon \\tNorth Korea \\tPyongyang \\t39,03 \\t125,75\\t\\n'], ['Northern Mariana Islands Flag Icon \\tNorthern Mariana Islands \\tSaipan \\t15,21 \\t145,75\\t\\n'], ['Norway Flag Icon \\tNorway \\tOslo \\t59,91 \\t10,75\\t\\n'], ['Oman Flag Icon \\tOman \\tMuscat \\t23,61 \\t58,59\\t\\n'], ['Pakistan Flag Icon \\tPakistan \\tIslamabad \\t33,72 \\t73,04\\t\\n'], ['Palau Flag Icon \\tPalau \\tMelekeok \\t7,50 \\t134,62\\t\\n'], ['Palestinian Territory Flag Icon \\tPalestinian Territory \\tEast Jerusalem \\t35,23 \\t31,77\\t\\n'], ['Panama Flag Icon \\tPanama \\tPanama City \\t8,99 \\t-79,52\\t\\n'], ['Papua New Guinea Flag Icon \\tPapua New Guinea \\tPort Moresby \\t-9,44 \\t147,18\\t\\n'], ['Paraguay Flag Icon \\tParaguay \\tAsunción \\t-25,30 \\t-57,64\\t\\n'], ['Peru Flag Icon \\tPeru \\tLima \\t-12,04 \\t-77,03\\t\\n'], ['Philippines Flag Icon \\tPhilippines \\tManila \\t14,60 \\t120,98\\t\\n'], ['Pitcairn Flag Icon \\tPitcairn \\tAdamstown \\t-25,07 \\t-130,10\\t\\n'], ['Poland Flag Icon \\tPoland \\tWarsaw \\t52,23 \\t21,01\\t\\n'], ['Portugal Flag Icon \\tPortugal \\tLisbon \\t38,72 \\t-9,13\\t\\n'], ['Puerto Rico Flag Icon \\tPuerto Rico \\tSan Juan \\t18,47 \\t-66,11\\t\\n'], ['Qatar Flag Icon \\tQatar \\tDoha \\t25,28 \\t51,52\\t\\n'], ['Republic of the Congo Flag Icon \\tRepublic of the Congo \\tBrazzaville \\t-4,27 \\t15,28\\t\\n'], ['Reunion Flag Icon \\tReunion \\tSaint-Denis \\t-20,88 \\t55,45\\t\\n'], ['Romania Flag Icon \\tRomania \\tBucharest \\t44,43 \\t26,11\\t\\n'], ['Russia Flag Icon \\tRussia \\tMoscow \\t55,75 \\t37,62\\t\\n'], ['Rwanda Flag Icon \\tRwanda \\tKigali \\t-1,95 \\t30,06\\t\\n'], ['Saint Barthélemy Flag Icon \\tSaint Barthélemy \\tGustavia \\t17,90 \\t-62,85\\t\\n'], ['Saint Helena Flag Icon \\tSaint Helena \\tJamestown \\t-15,94 \\t-5,72\\t\\n'], ['Saint Kitts and Nevis Flag Icon \\tSaint Kitts and Nevis \\tBasseterre \\t17,29 \\t-62,73\\t\\n'], ['Saint Lucia Flag Icon \\tSaint Lucia \\tCastries \\t14,00 \\t-61,01\\t\\n'], ['Saint Martin Flag Icon \\tSaint Martin \\tMarigot \\t18,07 \\t-63,08\\t\\n'], ['Saint Pierre and Miquelon Flag Icon \\tSaint Pierre and Miquelon \\tSaint-Pierre \\t46,78 \\t-56,17\\t\\n'], ['Saint Vincent and the Grenadines Flag Icon \\tSaint Vincent and the Grenadines \\tKingstown \\t13,16 \\t-61,22\\t\\n'], ['Samoa Flag Icon \\tSamoa \\tApia \\t-13,83 \\t-171,77\\t\\n'], ['San Marino Flag Icon \\tSan Marino \\tSan Marino \\t43,94 \\t12,45\\t\\n'], ['Sao Tome and Principe Flag Icon \\tSao Tome and Principe \\tSão Tomé \\t0,34 \\t6,73\\t\\n'], ['Saudi Arabia Flag Icon \\tSaudi Arabia \\tRiyadh \\t24,69 \\t46,72\\t\\n'], ['Senegal Flag Icon \\tSenegal \\tDakar \\t14,69 \\t-17,44\\t\\n'], ['Serbia Flag Icon \\tSerbia \\tBelgrade \\t44,80 \\t20,47\\t\\n'], ['Seychelles Flag Icon \\tSeychelles \\tVictoria \\t-4,62 \\t55,45\\t\\n'], ['Sierra Leone Flag Icon \\tSierra Leone \\tFreetown \\t8,48 \\t-13,23\\t\\n'], ['Singapore Flag Icon \\tSingapore \\tSingapore \\t1,29 \\t103,85\\t\\n'], ['Slovakia Flag Icon \\tSlovakia \\tBratislava \\t48,15 \\t17,11\\t\\n'], ['Slovenia Flag Icon \\tSlovenia \\tLjubljana \\t46,05 \\t14,51\\t\\n'], ['Solomon Islands Flag Icon \\tSolomon Islands \\tHoniara \\t-9,43 \\t159,95\\t\\n'], ['Somalia Flag Icon \\tSomalia \\tMogadishu \\t2,04 \\t45,34\\t\\n'], ['South Africa Flag Icon \\tSouth Africa \\tPretoria \\t-25,74 \\t28,19\\t\\n'], ['South Georgia and the South Sandwich Islands Flag Icon \\tSouth Georgia and the South Sandwich Islands \\tGrytviken \\t-54,28 \\t-36,51\\t\\n'], ['South Korea Flag Icon \\tSouth Korea \\tSeoul \\t37,57 \\t126,98\\t\\n'], ['Spain Flag Icon \\tSpain \\tMadrid \\t40,42 \\t-3,70\\t\\n'], ['Sri Lanka Flag Icon \\tSri Lanka \\tColombo \\t6,93 \\t79,85\\t\\n'], ['Sudan Flag Icon \\tSudan \\tKhartoum \\t15,55 \\t32,53\\t\\n'], ['Suriname Flag Icon \\tSuriname \\tParamaribo \\t5,87 \\t-55,17\\t\\n'], ['Svalbard and Jan Mayen Flag Icon \\tSvalbard and Jan Mayen \\tLongyearbyen \\t78,22 \\t15,64\\t\\n'], ['Swaziland Flag Icon \\tSwaziland \\tMbabane \\t-26,32 \\t31,13\\t\\n'], ['Sweden Flag Icon \\tSweden \\tStockholm \\t59,33 \\t18,06\\t\\n'], ['Switzerland Flag Icon \\tSwitzerland \\tBerne \\t46,95 \\t7,45\\t\\n'], ['Syria Flag Icon \\tSyria \\tDamascus \\t33,51 \\t36,29\\t\\n'], ['Taiwan Flag Icon \\tTaiwan \\tTaipei \\t25,05 \\t121,53\\t\\n'], ['Tajikistan Flag Icon \\tTajikistan \\tDushanbe \\t38,54 \\t68,78\\t\\n'], ['Tanzania Flag Icon \\tTanzania \\tDodoma \\t-6,17 \\t35,74\\t\\n'], ['Thailand Flag Icon \\tThailand \\tBangkok \\t13,75 \\t100,50\\t\\n'], ['Togo Flag Icon \\tTogo \\tLomé \\t6,14 \\t1,21\\t\\n'], ['Tokelau Flag Icon \\tTokelau \\tNukunonu \\t-171,85 \\t-9,20\\t\\n'], [\"Tonga Flag Icon \\tTonga \\tNuku'alofa \\t-21,13 \\t-175,20\\t\\n\"], ['Trinidad and Tobago Flag Icon \\tTrinidad and Tobago \\tPort of Spain \\t10,67 \\t-61,52\\t\\n'], ['Tunisia Flag Icon \\tTunisia \\tTunis \\t36,82 \\t10,17\\t\\n'], ['Turkey Flag Icon \\tTurkey \\tAnkara \\t39,92 \\t32,85\\t\\n'], ['Turkmenistan Flag Icon \\tTurkmenistan \\tAshkhabad \\t37,95 \\t58,38\\t\\n'], ['Turks and Caicos Islands Flag Icon \\tTurks and Caicos Islands \\tCockburn Town \\t21,46 \\t-71,14\\t\\n'], ['Tuvalu Flag Icon \\tTuvalu \\tFunafuti \\t-8,52 \\t179,19\\t\\n'], ['U.S. Virgin Islands Flag Icon \\tU.S. Virgin Islands \\tCharlotte Amalie \\t18,34 \\t-64,93\\t\\n'], ['Uganda Flag Icon \\tUganda \\tKampala \\t0,32 \\t32,58\\t\\n'], ['Ukraine Flag Icon \\tUkraine \\tKiev \\t50,45 \\t30,52\\t\\n'], ['United Arab Emirates Flag Icon \\tUnited Arab Emirates \\tAbu Dhabi \\t24,47 \\t54,37\\t\\n'], ['United Kingdom Flag Icon \\tUnited Kingdom \\tLondon \\t51,51 \\t-0,13\\t\\n'], ['United States Flag Icon \\tUnited States \\tWashington \\t38,90 \\t-77,04\\t\\n'], ['Uruguay Flag Icon \\tUruguay \\tMontevideo \\t-34,83 \\t-56,17\\t\\n'], ['Uzbekistan Flag Icon \\tUzbekistan \\tTashkent \\t41,26 \\t69,22\\t\\n'], ['Vanuatu Flag Icon \\tVanuatu \\tPort Vila \\t-17,73 \\t168,32\\t\\n'], ['Vatican Flag Icon \\tVatican \\tVatican \\t41,90 \\t12,45\\t\\n'], ['Venezuela Flag Icon \\tVenezuela \\tCaracas \\t10,49 \\t-66,88\\t\\n'], ['Vietnam Flag Icon \\tVietnam \\tHanoi \\t21,02 \\t105,84\\t\\n'], ['Wallis and Futuna Flag Icon \\tWallis and Futuna \\tMata-Utu \\t-13,28 \\t-176,17\\t\\n'], ['Western Sahara Flag Icon \\tWestern Sahara \\tEl Aaiún \\t27,16 \\t-13,20\\t\\n'], ['Yemen Flag Icon \\tYemen \\tSanaa \\t15,35 \\t44,21\\t\\n'], ['Zambia Flag Icon \\tZambia \\tLusaka \\t-15,41 \\t28,29\\t\\n'], ['Zimbabwe Flag Icon \\tZimbabwe \\tHarare \\t-17,83 \\t31,05']]\n"
          ],
          "name": "stdout"
        }
      ]
    },
    {
      "cell_type": "code",
      "metadata": {
        "colab": {
          "base_uri": "https://localhost:8080/",
          "height": 128
        },
        "id": "ZclYhVm4VwkK",
        "outputId": "3b5da471-639a-4b7a-f0ef-bf920ba60529"
      },
      "source": [
        "from pyspark import SparkContext\n",
        "sc = SparkContext.getOrCreate()\n",
        "capitalsRDD = sc.textFile('Capitals.txt')\n",
        "\n",
        "def splitAndTake(line):\n",
        "  arr = line.split(\" \\t\")\n",
        "  enlem = float(arr[3])\n",
        "  boylam = float(arr[4])\n",
        "  capital_city = arr[2]\n",
        "\n",
        "  return (capital_city,enlem,boylam)\n",
        "\n",
        "capitalsRDD =capitalsRDD.map(lambda a: splitAndTake(a))\n",
        "capitalsRDD =capitalsRDD.filter(lambda a : a[3]< abs(90) )\n",
        "capitalsRDD =capitalsRDD.filter(lambda b : b[4]< abs(180) )\n",
        "\n",
        "capitalsRDD.take(10):\n",
        "\n",
        "#sonra bunu listeye atıcaz\n",
        "\n",
        "def distance(enlem,oylam):\n",
        "\n",
        "  for \n",
        "\n"
      ],
      "execution_count": 26,
      "outputs": [
        {
          "output_type": "error",
          "ename": "SyntaxError",
          "evalue": "ignored",
          "traceback": [
            "\u001b[0;36m  File \u001b[0;32m\"<ipython-input-26-f00accf26fd1>\"\u001b[0;36m, line \u001b[0;32m17\u001b[0m\n\u001b[0;31m    capitalsRDD.take(10):\u001b[0m\n\u001b[0m                         ^\u001b[0m\n\u001b[0;31mSyntaxError\u001b[0m\u001b[0;31m:\u001b[0m invalid syntax\n"
          ]
        }
      ]
    },
    {
      "cell_type": "code",
      "metadata": {
        "colab": {
          "base_uri": "https://localhost:8080/",
          "height": 257
        },
        "id": "7V0ZYq6tQGH6",
        "outputId": "d64f79a0-ea94-4447-cec9-2a089e08b39e"
      },
      "source": [
        "import pandas as pd\n",
        "ulkelerDF = pd.read_csv('Capitals.txt', delimiter=' \\t', header= None, names=['Flag','Country','Capital','Enlem','Boylam'])\n",
        "ulkelerDF.columns=['Flag','Country','Capital','Enlem','Boylam']\n",
        "ulkelerDF.head()"
      ],
      "execution_count": 6,
      "outputs": [
        {
          "output_type": "stream",
          "text": [
            "/usr/local/lib/python3.7/dist-packages/ipykernel_launcher.py:2: ParserWarning: Falling back to the 'python' engine because the 'c' engine does not support regex separators (separators > 1 char and different from '\\s+' are interpreted as regex); you can avoid this warning by specifying engine='python'.\n",
            "  \n"
          ],
          "name": "stderr"
        },
        {
          "output_type": "execute_result",
          "data": {
            "text/html": [
              "<div>\n",
              "<style scoped>\n",
              "    .dataframe tbody tr th:only-of-type {\n",
              "        vertical-align: middle;\n",
              "    }\n",
              "\n",
              "    .dataframe tbody tr th {\n",
              "        vertical-align: top;\n",
              "    }\n",
              "\n",
              "    .dataframe thead th {\n",
              "        text-align: right;\n",
              "    }\n",
              "</style>\n",
              "<table border=\"1\" class=\"dataframe\">\n",
              "  <thead>\n",
              "    <tr style=\"text-align: right;\">\n",
              "      <th></th>\n",
              "      <th>Flag</th>\n",
              "      <th>Country</th>\n",
              "      <th>Capital</th>\n",
              "      <th>Enlem</th>\n",
              "      <th>Boylam</th>\n",
              "    </tr>\n",
              "  </thead>\n",
              "  <tbody>\n",
              "    <tr>\n",
              "      <th>0</th>\n",
              "      <td>Afghanistan Flag Icon</td>\n",
              "      <td>Afghanistan</td>\n",
              "      <td>Kabul</td>\n",
              "      <td>34,53</td>\n",
              "      <td>69,17</td>\n",
              "    </tr>\n",
              "    <tr>\n",
              "      <th>1</th>\n",
              "      <td>Albania Flag Icon</td>\n",
              "      <td>Albania</td>\n",
              "      <td>Tirana</td>\n",
              "      <td>41,33</td>\n",
              "      <td>19,82</td>\n",
              "    </tr>\n",
              "    <tr>\n",
              "      <th>2</th>\n",
              "      <td>Algeria Flag Icon</td>\n",
              "      <td>Algeria</td>\n",
              "      <td>Algiers</td>\n",
              "      <td>36,75</td>\n",
              "      <td>3,04</td>\n",
              "    </tr>\n",
              "    <tr>\n",
              "      <th>3</th>\n",
              "      <td>American Samoa Flag Icon</td>\n",
              "      <td>American Samoa</td>\n",
              "      <td>Pago Pago</td>\n",
              "      <td>-14,28</td>\n",
              "      <td>-170,70</td>\n",
              "    </tr>\n",
              "    <tr>\n",
              "      <th>4</th>\n",
              "      <td>Andorra Flag Icon</td>\n",
              "      <td>Andorra</td>\n",
              "      <td>Andorra la Vella</td>\n",
              "      <td>42,51</td>\n",
              "      <td>1,52</td>\n",
              "    </tr>\n",
              "  </tbody>\n",
              "</table>\n",
              "</div>"
            ],
            "text/plain": [
              "                       Flag         Country           Capital   Enlem   Boylam\n",
              "0     Afghanistan Flag Icon     Afghanistan             Kabul   34,53    69,17\n",
              "1         Albania Flag Icon         Albania            Tirana   41,33    19,82\n",
              "2         Algeria Flag Icon         Algeria           Algiers   36,75     3,04\n",
              "3  American Samoa Flag Icon  American Samoa         Pago Pago  -14,28  -170,70\n",
              "4         Andorra Flag Icon         Andorra  Andorra la Vella   42,51     1,52"
            ]
          },
          "metadata": {},
          "execution_count": 6
        }
      ]
    },
    {
      "cell_type": "code",
      "metadata": {
        "colab": {
          "base_uri": "https://localhost:8080/"
        },
        "id": "VIVEMp3CSICF",
        "outputId": "99b71443-ecac-40a2-d21e-96520de312d8"
      },
      "source": [
        "from pyspark.ml.regression import LinearRegression\n",
        "from pyspark.ml.feature import VectorAssembler\n",
        "from pyspark.ml.classification import DecisionTreeClassifier\n",
        "from pyspark.sql import SparkSession\n",
        "\n",
        "spark = SparkSession.builder.getOrCreate()\n",
        "evDF = spark.read.option('header','true').option('inferSchema','true').option('delimiter',';').csv('ev-fiyatlari.txt')\n",
        "\n",
        "#evDF.printSchema()\n",
        "\n",
        "vec = VectorAssembler(inputCols=['oda','salon','alan','yas'], outputCol='features')\n",
        "evDF = vec.transform(evDF)\n",
        "\n",
        "evDF = evDF.withColumnRenamed('fiyat','label')\n",
        "evDF.show()\n"
      ],
      "execution_count": 8,
      "outputs": [
        {
          "output_type": "stream",
          "text": [
            "+---+-----+----+---+------+--------------------+\n",
            "|oda|salon|alan|yas| label|            features|\n",
            "+---+-----+----+---+------+--------------------+\n",
            "|  3|    1| 180|  5|450000| [3.0,1.0,180.0,5.0]|\n",
            "|  2|    1| 110| 10|330000|[2.0,1.0,110.0,10.0]|\n",
            "|  3|    1| 200|  0|600000| [3.0,1.0,200.0,0.0]|\n",
            "|  2|    1|  80| 10|280000| [2.0,1.0,80.0,10.0]|\n",
            "|  1|    1|  70|  5|195000|  [1.0,1.0,70.0,5.0]|\n",
            "+---+-----+----+---+------+--------------------+\n",
            "\n"
          ],
          "name": "stdout"
        }
      ]
    },
    {
      "cell_type": "code",
      "metadata": {
        "colab": {
          "base_uri": "https://localhost:8080/"
        },
        "id": "76Z6gmbIVAhn",
        "outputId": "e86573c4-3975-45e8-b755-218c1268501f"
      },
      "source": [
        "from pyspark.ml.regression import LinearRegression\n",
        "from pyspark.ml.feature import VectorAssembler\n",
        "from pyspark.ml.classification import DecisionTreeClassifier\n",
        "from pyspark.sql import SparkSession\n",
        "\n",
        "spark = SparkSession.builder.getOrCreate()\n",
        "evDF = spark.read.option('header','true').option('inferSchema','true').option('delimiter',';').csv('ev-fiyatlari.txt')\n",
        "\n",
        "#evDF.printSchema()\n",
        "vec = VectorAssembler(inputCols=['oda','salon','alan','yas'], outputCol='features')\n",
        "evDF = vec.transform(evDF)\n",
        "\n",
        "evDF = evDF.withColumnRenamed('fiyat','label')\n",
        "#evDF.show()\n",
        "\n",
        "lr = LinearRegression()\n",
        "modelLR = lr.fit(evDF)\n",
        "print('bitti')\n",
        "print('Katsayilar (Coefficients): ', modelLR.coefficients)\n",
        "print(\"Sabit sayi (Intercept): \",modelLR.intercept)"
      ],
      "execution_count": 12,
      "outputs": [
        {
          "output_type": "stream",
          "text": [
            "bitti\n",
            "Katsayilar (Coefficients):  [96677.66068344089,0.0,881.5784548802857,-8809.21275403053]\n",
            "Sabit sayi (Intercept):  98322.38079593662\n"
          ],
          "name": "stdout"
        }
      ]
    },
    {
      "cell_type": "code",
      "metadata": {
        "id": "8LB_2dL0W6ki"
      },
      "source": [
        "def evfiyatiNedir(oda,salon,alan,yas):\n",
        "    fiyat = 96677 * oda + 0 * salon + 881 * alan + (-8809*yas) + 9832\n",
        "    return fiyat"
      ],
      "execution_count": 16,
      "outputs": []
    },
    {
      "cell_type": "code",
      "metadata": {
        "colab": {
          "base_uri": "https://localhost:8080/"
        },
        "id": "oQkXIzf_XZYA",
        "outputId": "8cfbcdc8-2609-4e9a-825c-8dabc3101139"
      },
      "source": [
        "a= evfiyatiNedir(2,1,190,1)\n",
        "print(a)"
      ],
      "execution_count": 17,
      "outputs": [
        {
          "output_type": "stream",
          "text": [
            "361767\n"
          ],
          "name": "stdout"
        }
      ]
    }
  ]
}