File tree Expand file tree Collapse file tree 3 files changed +14
-9
lines changed Expand file tree Collapse file tree 3 files changed +14
-9
lines changed Original file line number Diff line number Diff line change @@ -55,4 +55,13 @@ Result<std::unique_ptr<ManifestListReader>> ManifestListReader::MakeReader(
5555 return std::make_unique<ManifestListReaderImpl>(std::move (reader), std::move (schema));
5656}
5757
58+ Result<std::unique_ptr<ManifestListReader>> CreateManifestListReader (
59+ std::string_view file_path) {
60+ return NotImplemented (" CreateManifestListReader is not implemented yet." );
61+ }
62+
63+ Result<std::unique_ptr<ManifestReader>> CreateManifestReader (std::string_view file_path) {
64+ return NotImplemented (" CreateManifestReader is not implemented yet." );
65+ }
66+
5867} // namespace iceberg
Original file line number Diff line number Diff line change @@ -56,15 +56,11 @@ class ICEBERG_EXPORT ManifestListReader {
5656// / \param file_path Path to the manifest list file.
5757// / \return A Result containing the reader or an error.
5858Result<std::unique_ptr<ManifestListReader>> CreateManifestListReader (
59- std::string_view file_path) {
60- return NotImplemented (" CreateManifestListReader is not implemented yet." );
61- }
59+ std::string_view file_path);
6260
6361// / \brief Creates a reader for a manifest file.
6462// / \param file_path Path to the manifest file.
6563// / \return A Result containing the reader or an error.
66- Result<std::unique_ptr<ManifestReader>> CreateManifestReader (std::string_view file_path) {
67- return NotImplemented (" CreateManifestReader is not implemented yet." );
68- }
64+ Result<std::unique_ptr<ManifestReader>> CreateManifestReader (std::string_view file_path);
6965
7066} // namespace iceberg
Original file line number Diff line number Diff line change @@ -168,16 +168,16 @@ Result<std::vector<std::shared_ptr<FileScanTask>>> DataTableScan::PlanFiles() co
168168 std::vector<std::shared_ptr<FileScanTask>> tasks;
169169 for (const auto & manifest_file : manifest_files) {
170170 ICEBERG_ASSIGN_OR_RAISE (auto manifest_reader,
171- CreateManifestReader (manifest_file-> manifest_path ));
171+ CreateManifestReader (manifest_file. manifest_path ));
172172 ICEBERG_ASSIGN_OR_RAISE (auto manifests, manifest_reader->Entries ());
173173
174174 // TODO(gty404): filter manifests using partition spec and filter expression
175175
176176 for (auto & manifest_entry : manifests) {
177- const auto & data_file = manifest_entry-> data_file ;
177+ const auto & data_file = manifest_entry. data_file ;
178178 switch (data_file->content ) {
179179 case DataFile::Content::kData :
180- tasks.emplace_back (std::make_shared<FileScanTask>(manifest_entry-> data_file ));
180+ tasks.emplace_back (std::make_shared<FileScanTask>(manifest_entry. data_file ));
181181 break ;
182182 case DataFile::Content::kPositionDeletes :
183183 case DataFile::Content::kEqualityDeletes :
You can’t perform that action at this time.
0 commit comments