Skip to content

Commit aae2c37

Browse files
authored
fix(interactive): LocalWalParser not work currently (#4536)
Fixes
1 parent af2b61f commit aae2c37

File tree

2 files changed

+6
-4
lines changed

2 files changed

+6
-4
lines changed

flex/engines/graph_db/database/wal/local_wal_parser.cc

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,8 +22,10 @@
2222

2323
namespace gs {
2424

25-
LocalWalParser::LocalWalParser()
26-
: insert_wal_list_(NULL), insert_wal_list_size_(0) {}
25+
LocalWalParser::LocalWalParser(const std::string& wal_uri)
26+
: insert_wal_list_(NULL), insert_wal_list_size_(0) {
27+
LocalWalParser::open(wal_uri);
28+
}
2729

2830
void LocalWalParser::open(const std::string& wal_uri) {
2931
auto wal_dir = get_wal_uri_path(wal_uri);

flex/engines/graph_db/database/wal/local_wal_parser.h

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,10 +24,10 @@ namespace gs {
2424
class LocalWalParser : public IWalParser {
2525
public:
2626
static std::unique_ptr<IWalParser> Make(const std::string& wal_dir) {
27-
return std::unique_ptr<IWalParser>(new LocalWalParser());
27+
return std::unique_ptr<IWalParser>(new LocalWalParser(wal_dir));
2828
}
2929

30-
LocalWalParser();
30+
LocalWalParser(const std::string& wal_uri);
3131
~LocalWalParser() { close(); }
3232

3333
void open(const std::string& wal_uri) override;

0 commit comments

Comments
 (0)