Fix tests

This commit is contained in:
avogar 2022-05-10 16:20:38 +00:00
parent f6b16880bd
commit ea0362b3a3
5 changed files with 102 additions and 7 deletions

View File

@ -308,7 +308,6 @@ namespace DB
}
status = builder->AppendIndices(indexes.data(), indexes.size(), arrow_null_bytemap_raw_ptr);
std::cerr << assert_cast<arrow::DictionaryType *>(builder->type().get())->index_type()->name() << "\n";
checkStatus(status, column->getName(), format_name);
}

View File

@ -103,11 +103,18 @@ size_t JSONColumnsBaseBlockInputFormat::readColumn(
return column.size();
}
void JSONColumnsBaseBlockInputFormat::setReadBuffer(ReadBuffer & in_)
{
reader->setReadBuffer(in_);
IInputFormat::setReadBuffer(in_);
}
Chunk JSONColumnsBaseBlockInputFormat::generate()
{
MutableColumns columns = getPort().getHeader().cloneEmptyColumns();
block_missing_values.clear();
skipWhitespaceIfAny(*in);
if (in->eof())
return {};

View File

@ -48,6 +48,8 @@ public:
String getName() const override { return "JSONColumnsBaseBlockInputFormat"; }
void setReadBuffer(ReadBuffer & in_) override;
const BlockMissingValues & getMissingValues() const override { return block_missing_values; }
protected:

View File

@ -119,12 +119,12 @@
["0", "0", "9223372036854775807", "-9223372036854775808", "18446744073709551615", ["0"], ["0","0"]]
],
"totals": ["0","0","9223372036854775807","-9223372036854775808","18446744073709551615",["0"],["0","0"]],
"totals": ["0", "0", "9223372036854775807", "-9223372036854775808", "18446744073709551615", ["0"], ["0","0"]],
"extremes":
{
"min": ["0","0","9223372036854775807","-9223372036854775808","18446744073709551615",["0"],["0","0"]],
"max": ["0","0","9223372036854775807","-9223372036854775808","18446744073709551615",["0"],["0","0"]]
"min": ["0", "0", "9223372036854775807", "-9223372036854775808", "18446744073709551615", ["0"], ["0","0"]],
"max": ["0", "0", "9223372036854775807", "-9223372036854775808", "18446744073709551615", ["0"], ["0","0"]]
},
"rows": 1
@ -251,12 +251,12 @@
[0, 0, 9223372036854775807, -9223372036854775808, 18446744073709551615, [0], [0,0]]
],
"totals": [0,0,9223372036854775807,-9223372036854775808,18446744073709551615,[0],[0,0]],
"totals": [0, 0, 9223372036854775807, -9223372036854775808, 18446744073709551615, [0], [0,0]],
"extremes":
{
"min": [0,0,9223372036854775807,-9223372036854775808,18446744073709551615,[0],[0,0]],
"max": [0,0,9223372036854775807,-9223372036854775808,18446744073709551615,[0],[0,0]]
"min": [0, 0, 9223372036854775807, -9223372036854775808, 18446744073709551615, [0], [0,0]],
"max": [0, 0, 9223372036854775807, -9223372036854775808, 18446744073709551615, [0], [0,0]]
},
"rows": 1

File diff suppressed because one or more lines are too long