thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-24 02:30:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

Remove unused stream

Browse Source
This commit is contained in:
FawnD2 2020-05-04 17:47:09 +03:00
parent b492e92d41
commit da0a908d27
1 changed files with 0 additions and 33 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
src/Processors/Formats/Impl/ArrowBufferedStreams.cpp
View File

@ -14,39 +14,6 @@
namespace DB
{
ArrowBufferedInputStream::ArrowBufferedInputStream(ReadBuffer & in_) : in{in_}, is_open{true}
{
}
arrow::Status ArrowBufferedInputStream::Close()
{
is_open = false;
return arrow::Status::OK();
}
arrow::Status ArrowBufferedInputStream::Tell(int64_t * position) const
{
*position = total_length;
return arrow::Status::OK();
}
arrow::Status ArrowBufferedInputStream::Read(int64_t nbytes, int64_t * bytes_read, void * out)
{
size_t n = in.readBig(reinterpret_cast<char *>(out), nbytes);
*bytes_read = n;
total_length += n;
return arrow::Status::OK();
}
arrow::Status ArrowBufferedInputStream::Read(int64_t nbytes, std::shared_ptr<::arrow::Buffer> * out)
{
std::shared_ptr<arrow::Buffer> buf;
ARROW_RETURN_NOT_OK(arrow::AllocateBuffer(nbytes, &buf));
size_t n = in.readBig(reinterpret_cast<char *>(buf->mutable_data()), nbytes);
*out = arrow::SliceBuffer(buf, 0, n);
return arrow::Status::OK();
}
ArrowBufferedOutputStream::ArrowBufferedOutputStream(WriteBuffer & out_) : out{out_}, is_open{true}
{
}