@@ -1525,18 +1525,21 @@ class OlapOnDB : public OlapBase<EdgeData> {
1525
1525
if (output_filter != nullptr && !output_filter (i, vertex_data[i])) {
1526
1526
continue ;
1527
1527
}
1528
- auto vit = txn_.GetVertexIterator (OriginalVid (i));
1529
- auto vit_label = vit.GetLabel ();
1530
- auto primary_field = txn_.GetVertexPrimaryField (vit_label);
1531
- auto field_data = vit.GetField (primary_field);
1532
- json curJson;
1533
- curJson[" vid" ] = OriginalVid (i);
1534
- curJson[" label" ] = vit_label;
1535
- curJson[" primary_field" ] = primary_field;
1536
- curJson[" field_data" ] = field_data.ToString ();
1537
- curJson[" result" ] = vertex_data[i];
1538
- auto content = curJson.dump () + " \n " ;
1539
- fout.Write (content.c_str (), content.size ());
1528
+ auto vit = txn_.GetVertexIterator ();
1529
+ vit.Goto (OriginalVid (i));
1530
+ if (vit.IsValid ()) {
1531
+ auto vit_label = vit.GetLabel ();
1532
+ auto primary_field = txn_.GetVertexPrimaryField (vit_label);
1533
+ auto field_data = vit.GetField (primary_field);
1534
+ json curJson;
1535
+ curJson[" vid" ] = OriginalVid (i);
1536
+ curJson[" label" ] = vit_label;
1537
+ curJson[" primary_field" ] = primary_field;
1538
+ curJson[" field_data" ] = field_data.ToString ();
1539
+ curJson[" result" ] = vertex_data[i];
1540
+ auto content = curJson.dump () + " \n " ;
1541
+ fout.Write (content.c_str (), content.size ());
1542
+ }
1540
1543
}
1541
1544
}
1542
1545
0 commit comments