Skip to content

Commit

Permalink
Fix empty segment
Browse files Browse the repository at this point in the history
  • Loading branch information
willdealtry committed May 22, 2024
1 parent 38c65c7 commit 2f5ff92
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 2 deletions.
1 change: 1 addition & 0 deletions cpp/arcticdb/entity/stream_descriptor.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -122,6 +122,7 @@ struct StreamDescriptor {

explicit StreamDescriptor(const StreamId& id) {
set_id(id);
set_index({0, IndexDescriptor::Type::ROWCOUNT});
}

void add_scalar_field(DataType data_type, std::string_view name) {
Expand Down
4 changes: 2 additions & 2 deletions cpp/arcticdb/processing/operation_dispatch_binary.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -402,7 +402,7 @@ VariantData binary_operator(const ColumnWithStrings& col, const Value& val, Func
Column::transform<typename col_type_info::TDT, ScalarTagType<DataTypeTag<output_data_type>>>(
*(col.column_),
*output_column,
[&func, &col, &column_name, raw_value](auto input_value) -> ReversedTargetType {
[&func, raw_value](auto input_value) -> ReversedTargetType {
return func.apply(raw_value, input_value);
});
} else {
Expand All @@ -412,7 +412,7 @@ VariantData binary_operator(const ColumnWithStrings& col, const Value& val, Func
Column::transform<typename col_type_info::TDT, ScalarTagType<DataTypeTag<output_data_type>>>(
*(col.column_),
*output_column,
[&func, &col, &column_name, raw_value](auto input_value) -> TargetType {
[&func, raw_value](auto input_value) -> TargetType {
return func.apply(input_value, raw_value);
});
}
Expand Down

0 comments on commit 2f5ff92

Please sign in to comment.