feat(record): add record stub

Cargo.toml

@@ -13,6 +13,7 @@ serde = { version = "1.0", features = ["derive"]}
 librocksdb-sys = "0.11.0"
 thiserror = "1.0.44"
 vlseqid = "0.2.0"
+nummer = "0.2.1"
 
 
 [dependencies.rocksdb]
@@ -21,6 +22,24 @@ default-features = false
 features = ["multi-threaded-cf", "lz4"]
 
 
+[dependencies.arrow]
+package = "arrow2"
+git = "https://github.com/jorgecarleitao/arrow2"
+rev = "d5c78e7ba45fcebfbafd55a82ba2601ee3ea9617"
+version = "0.17.2"
+default-features = false
+features = [
+  "compute_aggregate",
+  "compute_arithmetics",
+  "compute_boolean",
+  "compute_boolean_kleene",
+  "compute_cast",
+  "compute_comparison",
+  "compute_concatenate",
+  "compute_filter",
+  "compute_if_then_else",
+]
+
 [dev-dependencies]
 tokio = "1.20.0"
 criterion = { version = "0.3", features = ["html_reports", "async_tokio"]}

src/record.rs

@@ -1,9 +1,11 @@
 use std::fmt::{Debug, Display};
 
+use arrow::datatypes::Field;
+use nummer::NDArray;
 use serde::{Deserialize, Serialize};
 use vlseqid::id::BigID;
 
-use crate::{serialization::BinCode, topic::TOPIC_KEY_PREFIX};
+use crate::{serialization::BinCode, topic::TOPIC_KEY_PREFIX, timestamp::Timestamp};
 
 pub type Record = Vec<u8>;
 
@@ -63,3 +65,34 @@ impl SeqRecord {
         self.key.to_string().starts_with(TOPIC_KEY_PREFIX)
     }
 }
+
+pub struct ValueIteration {
+    pub revision: u64,
+    pub version: u64,
+}
+
+pub struct RDFValue {
+    subject: Field,
+    predicate: Field,
+    object: Field,
+
+    iteration: ValueIteration,
+    created_at: Timestamp,
+}
+
+impl BinCode for RDFValue {}
+
+pub struct TensorValue<T> 
+where
+    T: Clone + Default
+{
+    tensor: NDArray<T>,
+
+    iteration: ValueIteration,
+    created_at: Timestamp,
+}
+
+impl<T> BinCode for TensorValue<T> 
+where
+    T: Clone + Default
+{}