Add a check for header structure.

This commit is contained in:
Nikolai Kochetov 2023-08-16 20:26:23 +00:00
parent 30ccfa1638
commit 91c241532f

View File

@ -27,6 +27,9 @@ public:
true)
, filter_transform(header_, expression_, filter_column_name_, remove_filter_column_, on_totals_)
{
assertBlocksHaveEqualStructure(
header_, getOutputPort().getHeader(),
"Expression for FilterSortedStreamByRange shoud not change header");
}
String getName() const override { return "FilterSortedStreamByRange"; }