csun5285 commented on code in PR #41625:
URL: https://github.com/apache/doris/pull/41625#discussion_r1820373189
##########
be/src/olap/rowset/beta_rowset_writer.cpp:
##########
@@ -891,13 +947,36 @@ Status BaseBetaRowsetWriter::create_file_writer(uint32_t
segment_id, io::FileWri
fmt::format("failed to create file = {}, file type = {}",
segment_path, file_type));
}
+Status BaseBetaRowsetWriter::create_inverted_index_file_writer(
+ uint32_t segment_id, InvertedIndexFileWriterPtr* index_file_writer) {
+
RETURN_IF_ERROR(RowsetWriter::create_inverted_index_file_writer(segment_id,
index_file_writer));
+ // used for inverted index format v1
+
(*index_file_writer)->set_file_writer_opts(_context.get_file_writer_options());
+ return Status::OK();
+}
+
Status BetaRowsetWriter::_create_segment_writer_for_segcompaction(
std::unique_ptr<segment_v2::SegmentWriter>* writer, int64_t begin,
int64_t end) {
DCHECK(begin >= 0 && end >= 0);
std::string path =
BetaRowset::local_segment_path_segcompacted(_context.tablet_path,
_context.rowset_id, begin, end);
io::FileWriterPtr file_writer;
RETURN_IF_ERROR(_create_file_writer(path, file_writer));
+ std::string prefix = std::string
{InvertedIndexDescriptor::get_index_file_path_prefix(path)};
Review Comment:
done
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
