thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-21 09:10:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix for timestamp & style

Browse Source
This commit is contained in:
Mikhail Filimonov 2019-12-05 22:21:15 +01:00
parent 34275626de
commit 7d760a964d
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
dbms/src/Storages/Kafka/KafkaBlockInputStream.cpp
View File

@ -136,12 +136,20 @@ Block KafkaBlockInputStream::readImpl()
auto _timestamp = _timestamp_raw ? std::chrono::duration_cast<std::chrono::seconds>(_timestamp_raw->get_timestamp()).count()
: 0;
for (size_t i = 0; i < new_rows; ++i) {
for (size_t i = 0; i < new_rows; ++i)
{
virtual_columns[0]->insert(_topic);
virtual_columns[1]->insert(_key);
virtual_columns[2]->insert(_offset);
virtual_columns[3]->insert(_partition);
virtual_columns[4]->insert(_timestamp);
if (_timestamp_raw)
{
virtual_columns[4]->insert(_timestamp);
}
else
{
virtual_columns[4]->insertDefault();
}
}
total_rows = total_rows + new_rows;