| 134 | } |
| 135 | |
| 136 | int ReadRowFromTable(tera::Table* table) { |
| 137 | tera::ErrorCode error_code; |
| 138 | tera::RowReader* row_reader = table->NewRowReader("com.baidu.www/"); |
| 139 | row_reader->AddColumnFamily("html"); |
| 140 | row_reader->AddColumn("anchor", "www.hao123.com/"); |
| 141 | row_reader->SetMaxVersions(3); |
| 142 | row_reader->SetAsync(); |
| 143 | row_reader->SetCallBack(ReadRowCallBack); |
| 144 | // Async Read one row |
| 145 | table->Get(row_reader); |
| 146 | |
| 147 | while (!finish) { |
| 148 | sleep(1); |
| 149 | } |
| 150 | |
| 151 | // Sync Read Batch Rows |
| 152 | |
| 153 | std::vector<tera::RowReader*> rows_reader; |
| 154 | tera::RowReader* row_reader1 = table->NewRowReader("com.baidu.www/"); |
| 155 | row_reader1->AddColumnFamily("html"); |
| 156 | row_reader1->SetMaxVersions(3); |
| 157 | row_reader1->SetTimeOut(5000); |
| 158 | rows_reader.push_back(row_reader1); |
| 159 | tera::RowReader* row_reader2 = table->NewRowReader("com.baidu.www/"); |
| 160 | row_reader2->AddColumnFamily("anchor"); |
| 161 | row_reader2->SetMaxVersions(3); |
| 162 | row_reader2->SetTimeOut(5000); |
| 163 | rows_reader.push_back(row_reader2); |
| 164 | table->Get(rows_reader); |
| 165 | |
| 166 | while (!row_reader1->Done()) { |
| 167 | printf("Row: %s\%s\%ld\%s\n", row_reader1->RowName().c_str(), row_reader1->ColumnName().c_str(), |
| 168 | row_reader1->Timestamp(), row_reader1->Value().c_str()); |
| 169 | row_reader1->Next(); |
| 170 | } |
| 171 | delete row_reader1; |
| 172 | while (!row_reader2->Done()) { |
| 173 | printf("Row: %s\%s\%ld\%s\n", row_reader2->RowName().c_str(), row_reader2->ColumnName().c_str(), |
| 174 | row_reader2->Timestamp(), row_reader2->Value().c_str()); |
| 175 | row_reader2->Next(); |
| 176 | } |
| 177 | delete row_reader2; |
| 178 | return 0; |
| 179 | } |
| 180 | |
| 181 | /// 三维表格 |
| 182 | int ShowBigTable(tera::Client* client) { |
no test coverage detected