thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-02 20:42:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix build error

Browse Source
This commit is contained in:
taiyang-li 2021-12-01 14:13:48 +08:00
parent d213500a3e
commit 4aeadf3967
4 changed files with 13 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/Formats/registerFormats.cpp
View File

@ -76,7 +76,10 @@ void registerInputFormatRegexp(FormatFactory & factory);
void registerInputFormatJSONAsString(FormatFactory & factory); void registerInputFormatJSONAsString(FormatFactory & factory);
void registerInputFormatLineAsString(FormatFactory & factory); void registerInputFormatLineAsString(FormatFactory & factory);
void registerInputFormatCapnProto(FormatFactory & factory); void registerInputFormatCapnProto(FormatFactory & factory);
#if USE_HIVE
void registerInputFormatHiveText(FormatFactory & factory); void registerInputFormatHiveText(FormatFactory & factory);
#endif
/// Non trivial prefix and suffix checkers for disabling parallel parsing. /// Non trivial prefix and suffix checkers for disabling parallel parsing.
void registerNonTrivialPrefixAndSuffixCheckerJSONEachRow(FormatFactory & factory); void registerNonTrivialPrefixAndSuffixCheckerJSONEachRow(FormatFactory & factory);
@ -148,7 +151,9 @@ void registerFormats()
registerInputFormatRegexp(factory); registerInputFormatRegexp(factory);
registerInputFormatJSONAsString(factory); registerInputFormatJSONAsString(factory);
registerInputFormatLineAsString(factory); registerInputFormatLineAsString(factory);
#if USE_HIVE
registerInputFormatHiveText(factory); registerInputFormatHiveText(factory);
#endif
registerInputFormatCapnProto(factory); registerInputFormatCapnProto(factory);

7
src/IO/RemoteReadBufferCache.cpp
View File

@ -29,7 +29,7 @@ namespace ErrorCodes
bool RemoteFileMetadata::load(const std::filesystem::path & local_path) bool RemoteFileMetadata::load(const std::filesystem::path & local_path)
{ {
auto log = &Poco::Logger::get("RemoteFileMetadata"); auto * log = &Poco::Logger::get("RemoteFileMetadata");
if (!std::filesystem::exists(local_path)) if (!std::filesystem::exists(local_path))
{ {
LOG_ERROR(log, "file path not exists:{}", local_path.string()); LOG_ERROR(log, "file path not exists:{}", local_path.string());
@ -49,13 +49,14 @@ bool RemoteFileMetadata::load(const std::filesystem::path & local_path)
return true; return true;
} }
void RemoteFileMetadata::save(const std::filesystem::path & local_path) void RemoteFileMetadata::save(const std::filesystem::path & local_path) const
{ {
std::ofstream meta_file(local_path.string(), std::ios::out); std::ofstream meta_file(local_path.string(), std::ios::out);
meta_file << toString(); meta_file << toString();
meta_file.close(); meta_file.close();
} }
String RemoteFileMetadata::toString()
String RemoteFileMetadata::toString() const
{ {
Poco::JSON::Object jobj; Poco::JSON::Object jobj;
jobj.set("schema", schema); jobj.set("schema", schema);

6
src/IO/RemoteReadBufferCache.h
View File

@ -49,8 +49,8 @@ struct RemoteFileMetadata
} }
bool load(const std::filesystem::path & local_path); bool load(const std::filesystem::path & local_path);
void save(const std::filesystem::path & local_path); void save(const std::filesystem::path & local_path) const;
String toString(); String toString() const;
String schema; // Hive, S2 etc. String schema; // Hive, S2 etc.
String cluster; String cluster;
@ -103,7 +103,7 @@ public:
inline size_t size() const { return current_offset; } inline size_t size() const { return current_offset; }
inline const std::filesystem::path & getLocalPath() { return local_path; } inline const std::filesystem::path & getLocalPath() { return local_path; }
inline const String & getRemotePath() { return file_meta_data.remote_path; } inline const String & getRemotePath() const { return file_meta_data.remote_path; }
inline UInt64 getLastModificationTimestamp() const { return file_meta_data.last_modification_timestamp; } inline UInt64 getLastModificationTimestamp() const { return file_meta_data.last_modification_timestamp; }
inline void markInvalid() inline void markInvalid()

1
src/Processors/Formats/Impl/HiveTextRowInputFormat.cpp
View File

@ -1,6 +1,7 @@
#include <Processors/Formats/Impl/HiveTextRowInputFormat.h> #include <Processors/Formats/Impl/HiveTextRowInputFormat.h>
#if USE_HIVE #if USE_HIVE
namespace DB namespace DB
{ {