mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-09-20 16:50:48 +00:00
make single if
This commit is contained in:
parent
c1cfc68cd6
commit
ad93644254
@ -30,13 +30,6 @@ Chunk ArrowBlockInputFormat::generate()
|
|||||||
{
|
{
|
||||||
Chunk res;
|
Chunk res;
|
||||||
const Block & header = getPort().getHeader();
|
const Block & header = getPort().getHeader();
|
||||||
|
|
||||||
if (!stream)
|
|
||||||
{
|
|
||||||
if (record_batch_current >= record_batch_total)
|
|
||||||
return res;
|
|
||||||
}
|
|
||||||
|
|
||||||
std::vector<std::shared_ptr<arrow::RecordBatch>> single_batch(1);
|
std::vector<std::shared_ptr<arrow::RecordBatch>> single_batch(1);
|
||||||
arrow::Status read_status;
|
arrow::Status read_status;
|
||||||
|
|
||||||
@ -48,6 +41,9 @@ Chunk ArrowBlockInputFormat::generate()
|
|||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
|
if (record_batch_current >= record_batch_total)
|
||||||
|
return res;
|
||||||
|
|
||||||
read_status = file_reader->ReadRecordBatch(record_batch_current, &single_batch[0]);
|
read_status = file_reader->ReadRecordBatch(record_batch_current, &single_batch[0]);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user