| 132 | } |
| 133 | |
| 134 | std::unique_ptr<common::FileInputStream> |
| 135 | OperatorTraceSplitReader::getSplitInputStream( |
| 136 | const std::string& traceDir) const { |
| 137 | auto splitInfoFile = fs_->openFileForRead(getOpTraceSplitFilePath(traceDir)); |
| 138 | if (splitInfoFile->size() == 0) { |
| 139 | LOG(WARNING) << "Split info is empty in " << traceDir; |
| 140 | return nullptr; |
| 141 | } |
| 142 | // TODO: Make the buffer size configurable. |
| 143 | return std::make_unique<common::FileInputStream>( |
| 144 | std::move(splitInfoFile), 1 << 20, pool_); |
| 145 | } |
| 146 | |
| 147 | // static |
| 148 | std::vector<std::string> OperatorTraceSplitReader::deserialize( |
nothing calls this directly
no test coverage detected