| 77 | |
| 78 | template<typename V> |
| 79 | void StreamReader<V>::init(const DataConfig& data) { |
| 80 | data_ = data; |
| 81 | if (data_.format() == DataConfig::TEXT) { |
| 82 | text_parser_.init(data_.text(), data_.ignore_feature_group()); |
| 83 | } |
| 84 | max_num_files_ = data_.file_size(); |
| 85 | if (data_.max_num_files_per_worker() >= 0) { |
| 86 | max_num_files_ = std::min(max_num_files_, data_.max_num_files_per_worker()); |
| 87 | } |
| 88 | openNextFile(); |
| 89 | } |
| 90 | |
| 91 | |
| 92 | template<typename V> |
nothing calls this directly
no test coverage detected