Lines Matching refs:cbt
28 namespace cbt = google::cloud::bigtable; in AsyncApply()
31 [](cbt::Table table, cbt::CompletionQueue cq, std::string const& row_key) { in AsyncApply()
35 cbt::SingleRowMutation mutation(row_key); in AsyncApply()
37 cbt::SetCell("fam", "column0", timestamp, "value for column0")); in AsyncApply()
39 cbt::SetCell("fam", "column1", timestamp, "value for column1")); in AsyncApply()
55 namespace cbt = google::cloud::bigtable; in AsyncBulkApply()
57 [](cbt::Table table, cbt::CompletionQueue cq) { in AsyncBulkApply()
59 cbt::BulkMutation bulk; in AsyncBulkApply()
72 cbt::SingleRowMutation mutation(buf); in AsyncBulkApply()
74 cbt::SetCell("fam", "col0", "value0-" + std::to_string(i))); in AsyncBulkApply()
76 cbt::SetCell("fam", "col1", "value2-" + std::to_string(i))); in AsyncBulkApply()
78 cbt::SetCell("fam", "col2", "value3-" + std::to_string(i))); in AsyncBulkApply()
80 cbt::SetCell("fam", "col3", "value4-" + std::to_string(i))); in AsyncBulkApply()
85 .then([](future<std::vector<cbt::FailedMutation>> ft) { in AsyncBulkApply()
111 namespace cbt = google::cloud::bigtable; in AsyncReadRows()
115 [](cbt::CompletionQueue cq, cbt::Table table) { in AsyncReadRows()
117 auto range = cbt::RowRange::Range("key-000010", "key-000020"); in AsyncReadRows()
120 auto filter = cbt::Filter::Chain( in AsyncReadRows()
121 cbt::Filter::ColumnRangeClosed("fam", "col0", "col0"), in AsyncReadRows()
122 cbt::Filter::Latest(1)); in AsyncReadRows()
127 [](cbt::Row const& row) { in AsyncReadRows()
152 namespace cbt = google::cloud::bigtable; in AsyncReadRowsWithLimit()
156 [](cbt::CompletionQueue cq, cbt::Table table) { in AsyncReadRowsWithLimit()
158 auto range = cbt::RowRange::Range("key-000010", "key-000020"); in AsyncReadRowsWithLimit()
161 auto filter = cbt::Filter::Chain( in AsyncReadRowsWithLimit()
162 cbt::Filter::ColumnRangeClosed("fam", "col0", "col0"), in AsyncReadRowsWithLimit()
163 cbt::Filter::Latest(1)); in AsyncReadRowsWithLimit()
168 [](cbt::Row const& row) { in AsyncReadRowsWithLimit()
193 namespace cbt = google::cloud::bigtable; in AsyncReadRow()
196 [](cbt::CompletionQueue cq, google::cloud::bigtable::Table table, in AsyncReadRow()
199 cbt::Filter filter = cbt::Filter::Latest(1); in AsyncReadRow()
202 [row_key](future<StatusOr<std::pair<bool, cbt::Row>>> row_future) { in AsyncReadRow()
235 namespace cbt = google::cloud::bigtable; in AsyncCheckAndMutate()
238 [](cbt::Table table, cbt::CompletionQueue cq, std::string const& row_key) { in AsyncCheckAndMutate()
240 cbt::Filter predicate = cbt::Filter::Chain( in AsyncCheckAndMutate()
241 cbt::Filter::ColumnRangeClosed("fam", "flip-flop", "flip-flop"), in AsyncCheckAndMutate()
242 cbt::Filter::Latest(1), cbt::Filter::ValueRegex("on")); in AsyncCheckAndMutate()
243 future<StatusOr<cbt::MutationBranch>> branch_future = in AsyncCheckAndMutate()
245 {cbt::SetCell("fam", "flip-flop", "off"), in AsyncCheckAndMutate()
246 cbt::SetCell("fam", "flop-flip", "on")}, in AsyncCheckAndMutate()
247 {cbt::SetCell("fam", "flip-flop", "on"), in AsyncCheckAndMutate()
248 cbt::SetCell("fam", "flop-flip", "off")}, in AsyncCheckAndMutate()
252 .then([](future<StatusOr<cbt::MutationBranch>> f) { in AsyncCheckAndMutate()
255 if (*response == cbt::MutationBranch::kPredicateMatched) { in AsyncCheckAndMutate()
271 namespace cbt = google::cloud::bigtable; in AsyncReadModifyWrite()
274 [](cbt::Table table, cbt::CompletionQueue cq, std::string const& row_key) { in AsyncReadModifyWrite()
275 future<StatusOr<cbt::Row>> row_future = table.AsyncReadModifyWriteRow( in AsyncReadModifyWrite()
277 cbt::ReadModifyWriteRule::AppendValue("fam", "list", ";element")); in AsyncReadModifyWrite()
280 .then([](future<StatusOr<cbt::Row>> f) { in AsyncReadModifyWrite()
300 namespace cbt = google::cloud::bigtable; in RunAll()
313 cbt::TableAdmin admin( in RunAll()
314 cbt::CreateDefaultAdminClient(project_id, cbt::ClientOptions{}), in RunAll()
330 cbt::TableConfig({{"fam", cbt::GcRule::MaxNumVersions(10)}}, {})); in RunAll()
337 table_id, cbt::AlwaysRetryMutationPolicy()); in RunAll()