Method ObserveCell

src/observer/executor/scanner_impl.cc:671–681

}

void ScannerImpl::ObserveCell(std::shared_ptr<NotifyCell> notify_cell) {
  observer_threads_->AddTask([=](int64_t) {
    Notification* notification = GetNotification(notify_cell);
    notify_cell->observer->OnNotify(notify_cell->notify_transaction.get(), tera_client_.get(),
                                    notify_cell->observed_column.table_name,
                                    notify_cell->observed_column.family,
                                    notify_cell->observed_column.qualifier, notify_cell->row,
                                    notify_cell->value, notify_cell->timestamp, notification);
    total_counter_.Inc();
  });
}

void ScannerImpl::ValidateAckConfict(RowReader* ack_reader) {
  NotificationContext* context = (NotificationContext*)(ack_reader->GetContext());