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

---

InsertOneSimTable

void Impala::Samples::MonetTest::InsertOneSimTable ( Connection *  conn, VideoSet *  vidSet, String  conceptSet, String  model, String  feature, int  fileIdx, String  concept, QuidTable *  quidTab   ) Definition at line 1262 of file mainMonetTest.cpp. References Impala::FileNameBase(), Impala::Core::Table::TableTem< Col1T, Col2T, Col3T, Col4T, Col5T, Col6T, Col7T, Col8T, Col9T >::Get1(), Impala::Core::Database::RawDataSet::GetDatabase(), Impala::Core::Database::RawDataSet::GetFilePathSimilarityData(), Impala::CmdOptions::GetInstance(), GetIntInRange(), Impala::Core::VideoSet::VideoSet::GetQuidVideo(), Impala::Core::Database::RawDataSet::GetSetNameBase(), ILOG_ERROR, ILOG_INFO, ILOG_VAR, Impala::MakeString(), Impala::QUID_CLASS_FRAME, Impala::QuidClass(), Impala::QuidId(), Impala::Core::Table::Read(), and Impala::Timer::SplitTime(). Referenced by DoSimilarities(). { typedef SimilarityTableSet::SimTableType SimTableType; ILOG_VAR(Impala.Samples.MonetTest.InsertOneSimTable); CmdOptions& options = CmdOptions::GetInstance(); SimTableType simTable(0); String path = vidSet->GetFilePathSimilarityData("Frames", conceptSet, model, feature, fileIdx, concept + "_sim.tab", false, false); if (path.empty()) return; Core::Table::Read(&simTable, path, vidSet->GetDatabase()); ILOG_INFO("simTable size = " << simTable.Size()); Quid vidQuid = vidSet->GetQuidVideo(fileIdx, true); conn->Query("delete from i_bulk_score;", false, false); int startScore = GetIntInRange("startScore", 0, simTable.Size(), false); int numberScores = GetIntInRange("numberScores", startScore, simTable.Size(), true); int bulkSize = 100000; Timer timer; for (int i=startScore ; i<startScore+numberScores ; i+=bulkSize) { int left = numberScores - 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 = vidSet->GetSetNameBase(); String conceptSetBase = FileNameBase(conceptSet); 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:

---