thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-11 08:52:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

rename some symboles

Browse Source
This commit is contained in:
taiyang-li 2021-12-21 15:00:47 +08:00
parent 40aa359201
commit 2fd63f9381
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/Storages/Hive/StorageHive.cpp
View File

@ -465,7 +465,7 @@ std::vector<HiveFilePtr> StorageHive::collectHiveFilesFromPartition(
hive_files.reserve(file_infos.size());
for (const auto & file_info : file_infos)
{
auto hive_file = createHiveFileIfValid(file_info, fields, query_info, context_);
auto hive_file = createHiveFileIfNeeded(file_info, fields, query_info, context_);
if (hive_file)
hive_files.push_back(hive_file);
}
@ -478,7 +478,7 @@ StorageHive::listDirectory(const String & path, HiveTableMetadataPtr hive_table_
return hive_table_metadata->getFilesByLocation(fs, path);
}
HiveFilePtr StorageHive::createHiveFileIfValid(
HiveFilePtr StorageHive::createHiveFileIfNeeded(
const FileInfo & file_info, const FieldVector & fields, SelectQueryInfo & query_info, ContextPtr context_)
{
LOG_TRACE(log, "Append hive file {}", file_info.path);
@ -575,7 +575,7 @@ Pipe StorageHive::read(
{
pool.scheduleOrThrowOnError([&]
{
auto hive_file = createHiveFileIfValid(file_info, {}, query_info, context_);
auto hive_file = createHiveFileIfNeeded(file_info, {}, query_info, context_);
if (hive_file)
{
std::lock_guard<std::mutex> lock(hive_files_mutex);

2
src/Storages/Hive/StorageHive.h
View File

@ -86,7 +86,7 @@ private:
ContextPtr context_);
HiveFilePtr
createHiveFileIfValid(const FileInfo & file_info, const FieldVector & fields, SelectQueryInfo & query_info, ContextPtr context_);
createHiveFileIfNeeded(const FileInfo & file_info, const FieldVector & fields, SelectQueryInfo & query_info, ContextPtr context_);
String hive_metastore_url;