@@ -21,7 +21,7 @@ def delete_from_column(project_id, instance_id, table_id):
2121 client = Client (project = project_id , admin = True )
2222 instance = client .instance (instance_id )
2323 table = instance .table (table_id )
24- row = table .row ("phone#4c410523#20190501" )
24+ row = table .direct_row ("phone#4c410523#20190501" )
2525 row .delete_cell (column_family_id = "cell_plan" , column = "data_plan_01gb" )
2626 row .commit ()
2727
@@ -36,7 +36,7 @@ def delete_from_column_family(project_id, instance_id, table_id):
3636 client = Client (project = project_id , admin = True )
3737 instance = client .instance (instance_id )
3838 table = instance .table (table_id )
39- row = table .row ("phone#4c410523#20190501" )
39+ row = table .direct_row ("phone#4c410523#20190501" )
4040 row .delete_cells (column_family_id = "cell_plan" , columns = row .ALL_COLUMNS )
4141 row .commit ()
4242
@@ -51,7 +51,7 @@ def delete_from_row(project_id, instance_id, table_id):
5151 client = Client (project = project_id , admin = True )
5252 instance = client .instance (instance_id )
5353 table = instance .table (table_id )
54- row = table .row ("phone#4c410523#20190501" )
54+ row = table .direct_row ("phone#4c410523#20190501" )
5555 row .delete ()
5656 row .commit ()
5757
@@ -69,7 +69,7 @@ def streaming_and_batching(project_id, instance_id, table_id):
6969 batcher = table .mutations_batcher (flush_count = 2 )
7070 rows = table .read_rows ()
7171 for row in rows :
72- row = table .row (row .row_key )
72+ row = table .direct_row (row .row_key )
7373 row .delete_cell (column_family_id = "cell_plan" , column = "data_plan_01gb" )
7474
7575 batcher .mutate_rows (rows )
@@ -86,7 +86,7 @@ def check_and_mutate(project_id, instance_id, table_id):
8686 client = Client (project = project_id , admin = True )
8787 instance = client .instance (instance_id )
8888 table = instance .table (table_id )
89- row = table .row ("phone#4c410523#20190501" )
89+ row = table .direct_row ("phone#4c410523#20190501" )
9090 row .delete_cell (column_family_id = "cell_plan" , column = "data_plan_01gb" )
9191 row .delete_cell (column_family_id = "cell_plan" , column = "data_plan_05gb" )
9292 row .commit ()
0 commit comments