MCPcopy Create free account
hub / github.com/ClickHouse/ClickHouse / next

Method next

src/Storages/ObjectStorage/StorageObjectStorageSource.cpp:1348–1360  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1346}
1347
1348ObjectInfoPtr StorageObjectStorageSource::GlobIterator::next(size_t processor)
1349{
1350 std::lock_guard lock(next_mutex);
1351 auto object_info = nextUnlocked(processor);
1352 if (first_iteration && !object_info && throw_on_zero_files_match)
1353 {
1354 throw Exception(ErrorCodes::FILE_DOESNT_EXIST,
1355 "Can not match any files with path {}",
1356 configuration->getPathForRead().path);
1357 }
1358 first_iteration = false;
1359 return object_info;
1360}
1361
1362ObjectInfoPtr StorageObjectStorageSource::GlobIterator::nextUnlocked(size_t /* processor */)
1363{

Callers 1

createReaderMethod · 0.45

Calls 15

getURIAndArchivePatternFunction · 0.85
createArchiveReaderFunction · 0.85
getPathForReadMethod · 0.80
setObjectMetadataMethod · 0.80
ExceptionClass · 0.50
FileProgressClass · 0.50
incrementFunction · 0.50
callbackFunction · 0.50
getContextFunction · 0.50
sizeMethod · 0.45
tryGetObjectMetadataMethod · 0.45

Tested by

no test coverage detected