|
233 | 233 | "source": [
|
234 | 234 | "import tensorflow as tf\n",
|
235 | 235 | "import numpy as np\n",
|
236 |
| - "import tensorflow_io.bigtable as bt\n", |
| 236 | + "import tensorflow_io as tfio\n", |
237 | 237 | "import random\n",
|
238 | 238 | "\n",
|
239 | 239 | "random.seed(10)"
|
|
268 | 268 | "# If using your bigtable instance replace the project_id, instance_id \n",
|
269 | 269 | "# and the name of the table with suitable values.\n",
|
270 | 270 | "\n",
|
271 |
| - "client = bt.BigtableClient(project_id=\"test-project\", instance_id=\"test-instance\")\n", |
| 271 | + "client = tfio.bigtable.BigtableClient(project_id=\"test-project\", instance_id=\"test-instance\")\n", |
272 | 272 | "train_table = client.get_table(\"t1\")"
|
273 | 273 | ]
|
274 | 274 | },
|
|
298 | 298 | },
|
299 | 299 | "outputs": [],
|
300 | 300 | "source": [
|
301 |
| - "row_set = bt.row_set.from_rows_or_ranges(bt.row_range.infinite())\n", |
| 301 | + "row_set = tfio.bigtable.row_set.from_rows_or_ranges(tfio.bigtable.row_range.infinite())\n", |
302 | 302 | "\n",
|
303 | 303 | "train_dataset = train_table.read_rows([\"cf1:c1\"],row_set, output_type=tf.string)\n",
|
304 | 304 | "\n",
|
|
364 | 364 | },
|
365 | 365 | "outputs": [],
|
366 | 366 | "source": [
|
367 |
| - "row_range_below_300 = bt.row_range.right_open(\"row000\", \"row300\")\n", |
| 367 | + "row_range_below_300 = tfio.bigtable.row_range.right_open(\"row000\", \"row300\")\n", |
368 | 368 | "\n",
|
369 |
| - "my_row_set = bt.row_set.from_rows_or_ranges(row_range_below_300, \"row585\", \"row832\")\n", |
| 369 | + "my_row_set = tfio.bigtable.row_set.from_rows_or_ranges(row_range_below_300, \"row585\", \"row832\")\n", |
370 | 370 | "print(my_row_set)"
|
371 | 371 | ]
|
372 | 372 | },
|
|
390 | 390 | },
|
391 | 391 | "outputs": [],
|
392 | 392 | "source": [
|
393 |
| - "my_truncated_row_set = bt.row_set.intersect(my_row_set,\n", |
394 |
| - " bt.row_range.right_open(\"row200\", \"row700\"))\n", |
| 393 | + "my_truncated_row_set = tfio.bigtable.row_set.intersect(my_row_set,\n", |
| 394 | + " tfio.bigtable.row_range.right_open(\"row200\", \"row700\"))\n", |
395 | 395 | "print(my_truncated_row_set)"
|
396 | 396 | ]
|
397 | 397 | },
|
|
426 | 426 | "\n",
|
427 | 427 | "start = datetime(2020, 10, 10, 12, 0, 0)\n",
|
428 | 428 | "end = datetime(2100, 10, 10, 13, 0, 0)\n",
|
429 |
| - "from_datetime = bt.filters.timestamp_range(start, end)\n", |
430 |
| - "from_posix_timestamp = bt.filters.timestamp_range(int(start.timestamp()), int(end.timestamp()))\n", |
| 429 | + "from_datetime = tfio.bigtable.filters.timestamp_range(start, end)\n", |
| 430 | + "from_posix_timestamp = tfio.bigtable.filters.timestamp_range(int(start.timestamp()), int(end.timestamp()))\n", |
431 | 431 | "print(\"from_datetime:\", from_datetime)\n",
|
432 | 432 | "\n",
|
433 | 433 | "print(\"from_posix_timestamp:\", from_posix_timestamp)"
|
|
0 commit comments