thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-16 03:12:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix style

Browse Source
This commit is contained in:
liuneng 2024-09-24 17:48:17 +08:00
parent 8faf2ea91e
commit 341f93d1b8
3 changed files with 16 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/Processors/Formats/Impl/ParquetBlockInputFormat.h
View File

@ -9,9 +9,11 @@
#include <queue>
namespace parquet {
namespace parquet
{
class ParquetFileReader;
class FileMetaData; }
class FileMetaData;
}
namespace parquet::arrow { class FileReader; }
namespace arrow { class Buffer; class RecordBatchReader;}
namespace arrow::io { class RandomAccessFile; }

16
src/Storages/ObjectStorage/HDFS/ReadBufferFromHDFS.cpp
View File

@ -173,13 +173,17 @@ struct ReadBufferFromHDFS::ReadBufferFromHDFSImpl : public BufferWithOwnMemory<S
if (bytes_read < 0)
{
throw Exception(ErrorCodes::HDFS_ERROR,
"Fail to read from HDFS: {}, file path: {}. Error: {}",
hdfs_uri, hdfs_file_path, std::string(hdfsGetLastError()));
throw Exception(
ErrorCodes::HDFS_ERROR,
"Fail to read from HDFS: {}, file path: {}. Error: {}",
hdfs_uri,
hdfs_file_path,
std::string(hdfsGetLastError()));
}
if (bytes_read && read_settings.remote_throttler)
{
read_settings.remote_throttler->add(bytes_read, ProfileEvents::RemoteReadThrottlerBytes, ProfileEvents::RemoteReadThrottlerSleepMicroseconds);
read_settings.remote_throttler->add(
bytes_read, ProfileEvents::RemoteReadThrottlerBytes, ProfileEvents::RemoteReadThrottlerSleepMicroseconds);
}
return bytes_read;
}
@ -269,10 +273,12 @@ String ReadBufferFromHDFS::getFileName() const
{
return impl->hdfs_file_path;
}
size_t ReadBufferFromHDFS::readBigAt(char * buffer, size_t size, size_t offset, const std::function<bool(size_t)> & ) const
size_t ReadBufferFromHDFS::readBigAt(char * buffer, size_t size, size_t offset, const std::function<bool(size_t)> &) const
{
return impl->pread(buffer, size, offset);
}
bool ReadBufferFromHDFS::supportsReadAt()
{
return true;

1
src/Storages/ObjectStorage/HDFS/ReadBufferFromHDFS.h
View File

@ -47,6 +47,7 @@ public:
String getFileName() const override;
size_t readBigAt(char * buffer, size_t size, size_t offset, const std::function<bool(size_t)> & function) const override;
bool supportsReadAt() override;
private: