MCPcopy Create free account
hub / github.com/baidu/tera / ReadRowFromTable

Function ReadRowFromTable

src/sample/tera_sample.cc:136–179  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

134}
135
136int 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/// 三维表格
182int ShowBigTable(tera::Client* client) {

Callers 1

ShowBigTableFunction · 0.85

Calls 15

SetAsyncMethod · 0.80
push_backMethod · 0.80
NewRowReaderMethod · 0.45
AddColumnFamilyMethod · 0.45
AddColumnMethod · 0.45
SetMaxVersionsMethod · 0.45
SetCallBackMethod · 0.45
GetMethod · 0.45
SetTimeOutMethod · 0.45
DoneMethod · 0.45
RowNameMethod · 0.45
ColumnNameMethod · 0.45

Tested by

no test coverage detected