feat(interactive): ImmutableCsr support multiple properties (#4505)

Fixes

Author: liulx20

.github/workflows/interactive.yml

@@ -533,7 +533,7 @@ jobs:
         SCHEMA_FILE=../tests/rt_mutable_graph/modern_graph_string_edge.yaml 
         BULK_LOAD_FILE=../interactive/examples/modern_graph/bulk_load.yaml
         GLOG_v=10 ./bin/bulk_loader  -g ${SCHEMA_FILE} -l ${BULK_LOAD_FILE} -d /tmp/csr-data-dir/
-        GLOG_v=10 ./tests/rt_mutable_graph/string_edge_property_test ${SCHEMA_FILE} /tmp/csr-data-dir/
+        GLOG_v=10 ./tests/rt_mutable_graph/string_edge_property_test /tmp/csr-data-dir/
     
 
     - name: Test update transaction
@@ -545,7 +545,7 @@ jobs:
         SCHEMA_FILE=../tests/rt_mutable_graph/modern_graph_string_edge.yaml 
         BULK_LOAD_FILE=../interactive/examples/modern_graph/bulk_load.yaml
         GLOG_v=10 ./bin/bulk_loader  -g ${SCHEMA_FILE} -l ${BULK_LOAD_FILE} -d /tmp/csr-data-dir/
-        GLOG_v=10 ./tests/rt_mutable_graph/test_update_transaction ${SCHEMA_FILE} /tmp/csr-data-dir/
+        GLOG_v=10 ./tests/rt_mutable_graph/test_update_transaction /tmp/csr-data-dir/
 
     - name: Test multiple properties edge
       env:
@@ -556,7 +556,18 @@ jobs:
         SCHEMA_FILE=../tests/rt_mutable_graph/modern_graph_multiple_props_edge.yaml
         BULK_LOAD_FILE=../tests/rt_mutable_graph/modern_graph_multiple_props_edge_import.yaml
         GLOG_v=10 ./bin/bulk_loader  -g ${SCHEMA_FILE} -l ${BULK_LOAD_FILE} -d /tmp/csr-data-dir/
-        GLOG_v=10 ./tests/rt_mutable_graph/multiple_props_edge_test ${SCHEMA_FILE} /tmp/csr-data-dir/
+        GLOG_v=10 ./tests/rt_mutable_graph/multiple_props_edge_test /tmp/csr-data-dir/
+    
+    - name: Test immutable csr
+      env:
+        FLEX_DATA_DIR: ${{ github.workspace }}/flex/interactive/examples/modern_graph/
+      run: |
+        rm -rf /tmp/csr-data-dir/
+        cd ${GITHUB_WORKSPACE}/flex/build/
+        SCHEMA_FILE=../tests/rt_mutable_graph/modern_graph_immutable_csr.yaml
+        BULK_LOAD_FILE=../tests/rt_mutable_graph/modern_graph_multiple_props_edge_import.yaml
+        GLOG_v=10 ./bin/bulk_loader  -g ${SCHEMA_FILE} -l ${BULK_LOAD_FILE} -d /tmp/csr-data-dir/
+        GLOG_v=10 ./tests/rt_mutable_graph/immutable_csr_test /tmp/csr-data-dir/
 
     - name: Test schema parsing and loading on modern graph
       env:

flex/engines/graph_db/database/read_transaction.h

@@ -89,6 +89,57 @@ class AdjListView {
   timestamp_t timestamp_;
 };
 
+template <typename EDATA_T>
+class ImmutableAdjListView {
+  class nbr_iterator {
+    using const_nbr_t = typename ImmutableNbrSlice<EDATA_T>::const_nbr_t;
+    using const_nbr_ptr_t =
+        typename ImmutableNbrSlice<EDATA_T>::const_nbr_ptr_t;
+
+   public:
+    nbr_iterator(const_nbr_ptr_t ptr, const_nbr_ptr_t end)
+        : ptr_(ptr), end_(end) {}
+
+    inline const_nbr_t& operator*() const { return *ptr_; }
+
+    inline const_nbr_ptr_t operator->() const { return ptr_; }
+
+    inline nbr_iterator& operator++() {
+      ++ptr_;
+      return *this;
+    }
+
+    inline bool operator==(const nbr_iterator& rhs) const {
+      return (ptr_ == rhs.ptr_);
+    }
+
+    inline bool operator!=(const nbr_iterator& rhs) const {
+      return (ptr_ != rhs.ptr_);
+    }
+
+   private:
+    const_nbr_ptr_t ptr_;
+    const_nbr_ptr_t end_;
+  };
+
+ public:
+  using slice_t = ImmutableNbrSlice<EDATA_T>;
+
+  ImmutableAdjListView(const slice_t& slice) : edges_(slice) {}
+
+  inline nbr_iterator begin() const {
+    return nbr_iterator(edges_.begin(), edges_.end());
+  }
+  inline nbr_iterator end() const {
+    return nbr_iterator(edges_.end(), edges_.end());
+  }
+
+  inline int estimated_degree() const { return edges_.size(); }
+
+ private:
+  slice_t edges_;
+};
+
 template <typename EDATA_T>
 class GraphView {
  public:
@@ -233,6 +284,19 @@ class GraphView {
   timestamp_t unsorted_since_;
 };
 
+template <typename EDATA_T>
+class ImmutableGraphView {
+ public:
+  ImmutableGraphView(const ImmutableCsr<EDATA_T>& csr) : csr_(csr) {}
+
+  inline ImmutableAdjListView<EDATA_T> get_edges(vid_t v) const {
+    return ImmutableAdjListView<EDATA_T>(csr_.get_edges(v));
+  }
+
+ private:
+  const ImmutableCsr<EDATA_T>& csr_;
+};
+
 template <typename EDATA_T>
 class SingleGraphView {
  public:
@@ -497,6 +561,22 @@ class ReadTransaction {
     return SingleImmutableGraphView<EDATA_T>(*csr);
   }
 
+  template <typename EDATA_T>
+  ImmutableGraphView<EDATA_T> GetOutgoingImmutableGraphView(
+      label_t v_label, label_t neighbor_label, label_t edge_label) const {
+    auto csr = dynamic_cast<const ImmutableCsr<EDATA_T>*>(
+        graph_.get_oe_csr(v_label, neighbor_label, edge_label));
+    return ImmutableGraphView<EDATA_T>(*csr);
+  }
+
+  template <typename EDATA_T>
+  ImmutableGraphView<EDATA_T> GetIncomingImmutableGraphView(
+      label_t v_label, label_t neighbor_label, label_t edge_label) const {
+    auto csr = dynamic_cast<const ImmutableCsr<EDATA_T>*>(
+        graph_.get_ie_csr(v_label, neighbor_label, edge_label));
+    return ImmutableGraphView<EDATA_T>(*csr);
+  }
+
   const GraphDBSession& GetSession() const;
 
  private:

flex/storages/rt_mutable_graph/csr/csr_base.h

@@ -142,13 +142,10 @@ class TypedMutableCsrBase : public TypedCsrBase<EDATA_T> {
 template <>
 class TypedCsrBase<RecordView> : public CsrBase {
  public:
-  using slice_t = MutableNbrSlice<RecordView>;
-
   virtual void batch_put_edge_with_index(vid_t src, vid_t dst, size_t index,
                                          timestamp_t ts = 0) = 0;
   virtual void put_edge_with_index(vid_t src, vid_t dst, size_t index,
                                    timestamp_t ts, Allocator& alloc) = 0;
-  virtual slice_t get_edges(vid_t v) const = 0;
 };
 
 }  // namespace gs