Definition at line 926 of file RawDataSet.h. References AddFile(), Impala::Util::StringParser::At(), Impala::Util::IOBuffer::Available(), Impala::Util::StringParser::Eat(), Impala::FileNameBase(), Impala::Util::StringParser::GetInt(), Impala::Util::Database::GetIOBuffer(), Impala::Util::StringParser::GetString2(), ILOG_DEBUG, mDb, mHasFiles, mLastId, mLastKeyForWarning, mProtocolAndHost, mQuidClass, mSetFileName, mSetName, mSetNameBase, Impala::QUID_CLASS_UNKNOWN, Impala::Util::IOBuffer::ReadLine(), Impala::Timer::SplitTime(), Impala::StringReplaceAll(), Impala::Util::StringParser::TheEnd(), and Impala::Util::IOBuffer::Valid(). 00927 { 00928 mLastKeyForWarning = -1; 00929 mDb = db; 00930 mSetName = setName; 00931 mSetNameBase = FileNameBase(mSetName); 00932 mSetFileName = setFileName; 00933 mProtocolAndHost = "not_set"; 00934 mHasFiles = false; 00935 mLastId = 0; 00936 if (mSetFileName == String("")) 00937 return; 00938 mQuidClass = QUID_CLASS_UNKNOWN; 00939 ILOG_DEBUG("opening data file " << mSetFileName); 00940 Timer timer(1); 00941 Util::IOBuffer* f = mDb->GetIOBuffer(mSetFileName, true, true, ""); 00942 if (f->Valid()) 00943 { 00944 while (f->Available()) 00945 { 00946 String line = f->ReadLine(); 00947 if (line[0] && (line[0] != '#')) 00948 { 00949 int id = -1; 00950 String name(""); 00951 Util::StringParser p(line); 00952 while (!p.TheEnd()) 00953 { 00954 if (p.At("<id=")) 00955 { 00956 p.Eat('='); 00957 id = p.GetInt('>', true); 00958 p.Eat('>'); 00959 } 00960 else 00961 { 00962 String s = p.GetString2(false); 00963 name = StringReplaceAll(s, "\\", "/"); 00964 } 00965 } 00966 AddFile(name, id); 00967 } 00968 } 00969 } 00970 delete f; 00971 ILOG_DEBUG("done read file in " << timer.SplitTime()); 00972 }
Here is the call graph for this function:
|