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

Function SerializeMutation

src/sdk/mutate_impl.cc:328–391  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

326}
327
328void SerializeMutation(const RowMutation::Mutation& src, tera::Mutation* dst) {
329 switch (src.type) {
330 case RowMutation::kPut:
331 dst->set_type(tera::kPut);
332 dst->set_family(src.family);
333 dst->set_qualifier(src.qualifier);
334 dst->set_timestamp(src.timestamp);
335 dst->set_value(src.value);
336 dst->set_ttl(src.ttl);
337 break;
338 case RowMutation::kAdd:
339 dst->set_type(tera::kAdd);
340 dst->set_family(src.family);
341 dst->set_qualifier(src.qualifier);
342 dst->set_timestamp(src.timestamp);
343 dst->set_value(src.value);
344 break;
345 case RowMutation::kAddInt64:
346 dst->set_type(tera::kAddInt64);
347 dst->set_family(src.family);
348 dst->set_qualifier(src.qualifier);
349 dst->set_timestamp(src.timestamp);
350 dst->set_value(src.value);
351 break;
352 case RowMutation::kPutIfAbsent:
353 dst->set_type(tera::kPutIfAbsent);
354 dst->set_family(src.family);
355 dst->set_qualifier(src.qualifier);
356 dst->set_timestamp(src.timestamp);
357 dst->set_value(src.value);
358 break;
359 case RowMutation::kAppend:
360 dst->set_type(tera::kAppend);
361 dst->set_family(src.family);
362 dst->set_qualifier(src.qualifier);
363 dst->set_timestamp(src.timestamp);
364 dst->set_value(src.value);
365 break;
366 case RowMutation::kDeleteColumn:
367 dst->set_type(tera::kDeleteColumn);
368 dst->set_family(src.family);
369 dst->set_qualifier(src.qualifier);
370 dst->set_timestamp(src.timestamp);
371 break;
372 case RowMutation::kDeleteColumns:
373 dst->set_type(tera::kDeleteColumns);
374 dst->set_family(src.family);
375 dst->set_qualifier(src.qualifier);
376 dst->set_timestamp(src.timestamp);
377 break;
378 case RowMutation::kDeleteFamily:
379 dst->set_type(tera::kDeleteFamily);
380 dst->set_family(src.family);
381 dst->set_timestamp(src.timestamp);
382 break;
383 case RowMutation::kDeleteRow:
384 dst->set_type(tera::kDeleteRow);
385 dst->set_timestamp(src.timestamp);

Callers 2

CommitBatchMutationsMethod · 0.85
CommitMutationsMethod · 0.85

Calls

no outgoing calls

Tested by

no test coverage detected