Misc fixes regarding connection.

Author: dsevilla

hbase/sesion5.ipynb

@@ -226,7 +226,7 @@
       },
       "outputs": [],
       "source": [
-        "pool = Connection(HBASEHOST)"
+        "hbasecon = Connection(HBASEHOST)"
       ]
     },
     {
@@ -250,7 +250,7 @@
         "tables: list[str] = ['posts', 'votes', 'users', 'tags', 'comments']\n",
         "for t in tables:\n",
         "    try:\n",
-        "        with pool.connection() as connection:\n",
+        "        with hbasecon.connection() as connection:\n",
         "            connection.create_table(\n",
         "                t,\n",
         "                {\n",
@@ -259,7 +259,7 @@
         "    except Exception as e:\n",
         "        print(\"Database already exists: {0}. {1}\".format(t, e))\n",
         "        pass\n",
-        "with pool.connection() as connection:\n",
+        "with hbasecon.connection() as connection:\n",
         "    print(connection.tables())"
       ]
     },
@@ -328,7 +328,7 @@
         "from happybase import Table\n",
         "\n",
         "def csv_to_hbase(file: str, tablename: str, column_family: str):\n",
-        "    with pool.connection() as connection, open(file) as f:\n",
+        "    with hbasecon.connection() as connection, open(file) as f:\n",
         "        table: Table = connection.table(tablename)\n",
         "\n",
         "        # La llamada csv.reader() crea un iterador sobre un fichero CSV\n",
@@ -436,7 +436,7 @@
       },
       "outputs": [],
       "source": [
-        "with pool.connection() as connection:\n",
+        "with hbasecon.connection() as connection:\n",
         "    posts = connection.table('posts')"
       ]
     },
@@ -637,7 +637,7 @@
       },
       "outputs": [],
       "source": [
-        "with pool.connection() as connection:\n",
+        "with hbasecon.connection() as connection:\n",
         "    comments = connection.table('comments')\n",
         "    posts = connection.table('posts')\n",
         "\n",
@@ -876,7 +876,7 @@
       },
       "outputs": [],
       "source": [
-        "with pool.connection() as connection:\n",
+        "with hbasecon.connection() as connection:\n",
         "    FillWikiTable(connection).run()"
       ]
     },
@@ -974,7 +974,7 @@
       },
       "outputs": [],
       "source": [
-        "with pool.connection() as connection:\n",
+        "with hbasecon.connection() as connection:\n",
         "    BuildLinks(connection).run()"
       ]
     },
@@ -1073,7 +1073,7 @@
       },
       "outputs": [],
       "source": [
-        "with pool.connection() as connection:\n",
+        "with hbasecon.connection() as connection:\n",
         "  visualize_result_wikipedia(connection.table('wikilinks'))"
       ]
     },

hbase/sesion6.ipynb

@@ -240,15 +240,6 @@
         "    print(connection.tables())"
       ]
     },
-    {
-      "cell_type": "code",
-      "execution_count": null,
-      "metadata": {},
-      "outputs": [],
-      "source": [
-        "pool = Connection(HBASEHOST)"
-      ]
-    },
     {
       "cell_type": "markdown",
       "metadata": {
@@ -348,7 +339,7 @@
         "from happybase import Table\n",
         "\n",
         "def csv_to_hbase(file: str, tablename: str, column_family: str):\n",
-        "    with pool.connection() as connection, open(file) as f:\n",
+        "    with hbasecon.connection() as connection, open(file) as f:\n",
         "        table: Table = connection.table(tablename)\n",
         "\n",
         "        # La llamada csv.reader() crea un iterador sobre un fichero CSV\n",
@@ -456,7 +447,7 @@
       },
       "outputs": [],
       "source": [
-        "def posts():\n",
+        "def posts() -> Table:\n",
         "  with hbasecon.connection() as connection:\n",
         "    return connection.table('posts')"
       ]