|| || || || || || || ||

---

SaveSim

void Impala::Persistency::SimilarityTableSetRepositoryInMonet::SaveSim ( SimilarityTableSet *  simSet, int  tableIdx, const SimilarityTableSetLocator &  loc   ) [inline, private] Definition at line 176 of file SimilarityTableSetRepositoryInMonet.h. References Impala::FileNameBase(), Impala::Core::Table::TableTem< Col1T, Col2T, Col3T, Col4T, Col5T, Col6T, Col7T, Col8T, Col9T >::Get1(), Impala::Persistency::SimilarityTableSetLocator::GetConceptSet(), Impala::Persistency::RepositoryInMonetDB::GetConnection(), Impala::Persistency::SimilarityTableSetLocator::GetContainer(), Impala::Persistency::Locator::GetDataSet(), Impala::Persistency::SimilarityTableSetLocator::GetFeature(), Impala::Core::Database::RawDataSet::GetFileId(), Impala::Persistency::SimilarityTableSetLocator::GetModel(), Impala::Core::Table::SimilarityTableSet::GetName(), Impala::Core::Table::SimilarityTableSet::GetQuidTable(), Impala::Core::VideoSet::VideoSet::GetQuidVideo(), Impala::Core::Table::SimilarityTableSet::GetSimTable(), ILOG_ERROR, ILOG_INFO, Impala::MakeString(), Impala::QUID_CLASS_FRAME, Impala::QuidClass(), Impala::QuidId(), RepMonet(), Impala::Core::Table::Table::Size(), and Impala::Timer::SplitTime(). Referenced by SaveSims(). { typedef SimilarityTableSet::SimTableType SimTableType; Connection* conn = RepMonet().GetConnection(loc); Core::VideoSet::VideoSet* vidSet = VideoSetRepository().Get(loc); int fileIdx = vidSet->GetFileId(loc.GetContainer()); Quid vidQuid = vidSet->GetQuidVideo(fileIdx, false); SimTableType* simTable = simSet->GetSimTable(tableIdx); QuidTable* quidTab = simSet->GetQuidTable(); int bulkSize = 100000; Timer timer; for (int i=0 ; i<simTable->Size() ; i+=bulkSize) { int left = simTable->Size() - i; int nr = (left > bulkSize) ? bulkSize : left; String q = "copy " + MakeString(nr) + " records into i_bulk_score from stdin using delimiters ' ';\n"; for (int j=i ; j<i+nr ; j++) { Quid frameQuid = quidTab->Get1(j); if (QuidClass(frameQuid) != QUID_CLASS_FRAME) ILOG_ERROR("Quid is not a frame"); int frameNr = QuidId(frameQuid); q += MakeString(vidQuid) + " " + MakeString(frameNr) + " " + MakeString(simTable->Get1(j)) + "\n"; } conn->Query(q, false, false); ILOG_INFO("Did bulk at " << timer.SplitTime()); } String vidSetBase = FileNameBase(loc.GetDataSet()); String conceptSetBase = FileNameBase(loc.GetConceptSet()); String model = loc.GetModel(); String feature = loc.GetFeature(); String concept = simSet->GetName(tableIdx); String q = "select i_add_feature('" + feature + "');"; ILOG_INFO("q = [" + q + "]"); conn->Query(q, false, false); q = "select i_add_model('" + vidSetBase + "', '" + conceptSetBase + "', '" + concept + "', '" + model + "', '" + feature + "');"; ILOG_INFO("q = [" + q + "]"); conn->Query(q, false, false); // a model is also a set with itself as element q = "select i_add_model_sets('" + vidSetBase + "', '" + conceptSetBase + "', '" + concept + "', '" + model + "', '" + feature + "');"; ILOG_INFO("q = [" + q + "]"); conn->Query(q, false, false); q = "select i_add_model_to_set('" + vidSetBase + "', '" + conceptSetBase + "', '" + concept + "', '" + model + "', '" + feature + "', '" + feature + "');"; ILOG_INFO("q = [" + q + "]"); conn->Query(q, false, false); conn->Query("insert into score (fragment_id, model_sets_id, file_id, \ confidence) \ select fr.fragment_id, mss.model_sets_id, f.file_id, \ bs.confidence \ from video_sets vss, video_set vs, keyword_sets kss, \ keyword_set ks, keyword k, model_sets_name msn, \ model_sets mss, model_ref mr, \ file f, fragment fr, i_bulk_score bs \ where vss.set_name = '" + vidSetBase + "' and \ kss.set_name = '" + conceptSetBase + "' and \ kss.video_sets_id = vss.video_sets_id and \ msn.set_name = '" + feature + "' and \ mss.model_sets_name_id = msn.model_sets_name_id and \ k.keyword_name = '" + concept + "' and \ ks.keyword_sets_id = kss.keyword_sets_id and \ ks.keyword_id = k.keyword_id and \ mr.model_name = '" + model + "' and \ mr.keyword_set_id = ks.keyword_set_id and \ mr.model_ref_id = mss.model_ref_id and \ vs.video_sets_id = vss.video_sets_id and \ f.file_id = vs.file_id and \ bs.quid = f.quid and \ fr.media_id = f.media_id and \ fr.fragment_start = bs.fragment_start and \ fr.fragment_length = 1 and \ fr.keyframe = false \ order by bs.fragment_start;", false, false); ILOG_INFO("Did insert select at " << timer.SplitTime()); conn->Query("delete from i_bulk_score;", false, false); ILOG_INFO("Done in " << timer.SplitTime()); } Here is the call graph for this function:

---