|
233 | 233 | "source": [ |
234 | 234 | "import tensorflow as tf\n", |
235 | 235 | "import numpy as np\n", |
236 | | - "import tensorflow_io as tfio\n", |
| 236 | + "import tensorflow_io.bigtable as bt\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 = tfio.bigtable.BigtableClient(project_id=\"test-project\", instance_id=\"test-instance\")\n", |
| 271 | + "client = bt.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 = tfio.bigtable.row_set.from_rows_or_ranges(tfio.bigtable.row_range.infinite())\n", |
| 301 | + "row_set = bt.row_set.from_rows_or_ranges(bt.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 = tfio.bigtable.row_range.right_open(\"row000\", \"row300\")\n", |
| 367 | + "row_range_below_300 = bt.row_range.right_open(\"row000\", \"row300\")\n", |
368 | 368 | "\n", |
369 | | - "my_row_set = tfio.bigtable.row_set.from_rows_or_ranges(row_range_below_300, \"row585\", \"row832\")\n", |
| 369 | + "my_row_set = bt.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 = tfio.bigtable.row_set.intersect(my_row_set,\n", |
394 | | - " tfio.bigtable.row_range.right_open(\"row200\", \"row700\"))\n", |
| 393 | + "my_truncated_row_set = bt.row_set.intersect(my_row_set,\n", |
| 394 | + " bt.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 = tfio.bigtable.filters.timestamp_range(start, end)\n", |
430 | | - "from_posix_timestamp = tfio.bigtable.filters.timestamp_range(int(start.timestamp()), int(end.timestamp()))\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", |
431 | 431 | "print(\"from_datetime:\", from_datetime)\n", |
432 | 432 | "\n", |
433 | 433 | "print(\"from_posix_timestamp:\", from_posix_timestamp)" |
|
0 commit comments