add todos

eggstrain/src/execution/operators/filter.rs

@@ -10,11 +10,13 @@ use std::sync::Arc;
 use tokio::sync::broadcast;
 use tokio::sync::broadcast::error::RecvError;
 
+/// TODO docs
 pub struct Filter {
     pub predicate: Arc<dyn PhysicalExpr>,
     pub children: Vec<Arc<dyn ExecutionPlan>>,
 }
 
+/// TODO docs
 impl Filter {
     pub fn new(predicate: Arc<dyn PhysicalExpr>, children: Vec<Arc<dyn ExecutionPlan>>) -> Self {
         Self {
@@ -23,7 +25,8 @@ impl Filter {
         }
     }
 
-    /// https://docs.rs/datafusion-physical-plan/36.0.0/src/datafusion_physical_plan/filter.rs.html#307
+    /// Taken from DataFusion's `FilterExec`
+    /// [code](https://docs.rs/datafusion-physical-plan/36.0.0/src/datafusion_physical_plan/filter.rs.html#307)
     pub fn batch_filter(&self, batch: RecordBatch) -> Result<RecordBatch> {
         self.predicate
             .evaluate(&batch)
@@ -36,12 +39,14 @@ impl Filter {
     }
 }
 
+/// TODO docs
 impl Operator for Filter {
     fn children(&self) -> Vec<Arc<dyn ExecutionPlan>> {
         self.children.clone()
     }
 }
 
+/// TODO docs
 #[async_trait]
 impl UnaryOperator for Filter {
     type In = RecordBatch;

eggstrain/src/execution/operators/mod.rs

@@ -6,10 +6,16 @@ use tokio::sync::broadcast::{Receiver, Sender};
 pub mod filter;
 pub mod project;
 
+/// Defines shared behavior for all operators
+///
+/// TODO docs
 pub trait Operator {
     fn children(&self) -> Vec<Arc<dyn ExecutionPlan>>;
 }
 
+/// Defines shared behavior for operators with a single logical input
+///
+/// TODO docs
 #[async_trait]
 pub(crate) trait UnaryOperator: Operator + Send + Sync {
     type In;
@@ -20,6 +26,9 @@ pub(crate) trait UnaryOperator: Operator + Send + Sync {
     async fn execute(&self, rx: Receiver<Self::In>, tx: Sender<Self::Out>);
 }
 
+/// Defines shared behavior for operators with a two logical inputs (like joins)
+///
+/// TODO docs
 #[async_trait]
 pub(crate) trait BinaryOperator: Operator + Send + Sync {
     type InLeft;

eggstrain/src/execution/operators/project.rs

@@ -8,13 +8,15 @@ use std::sync::Arc;
 use tokio::sync::broadcast;
 use tokio::sync::broadcast::error::RecvError;
 
+/// TODO docs
 pub struct Project {
     pub output_expr: Vec<(Arc<dyn PhysicalExpr>, String)>,
     pub input_schema: SchemaRef, // TODO
     pub output_schema: SchemaRef,
     pub children: Vec<Arc<dyn ExecutionPlan>>,
 }
 
+/// TODO docs
 impl Project {
     pub fn new(input_schema: SchemaRef, projection_plan: &ProjectionExec) -> Self {
         Self {
@@ -42,12 +44,14 @@ impl Project {
     }
 }
 
+/// TODO docs
 impl Operator for Project {
     fn children(&self) -> Vec<Arc<dyn ExecutionPlan>> {
         self.children.clone()
     }
 }
 
+/// TODO docs
 #[async_trait]
 impl UnaryOperator for Project {
     type In = RecordBatch;