diff --git a/src/logging.rs b/src/logging.rs index 4d7de783d..628f283af 100644 --- a/src/logging.rs +++ b/src/logging.rs @@ -1,5 +1,6 @@ //! Loggers and logging events for differential dataflow. +use columnar::Columnar; use serde::{Deserialize, Serialize}; /// Logger for differential dataflow events. @@ -19,7 +20,7 @@ where } /// Possible different differential events. -#[derive(Debug, Clone, Ord, PartialOrd, Eq, PartialEq, Serialize, Deserialize)] +#[derive(Debug, Clone, Ord, PartialOrd, Eq, PartialEq, Serialize, Deserialize, Columnar)] pub enum DifferentialEvent { /// Batch creation. Batch(BatchEvent), @@ -36,7 +37,7 @@ pub enum DifferentialEvent { } /// Either the start or end of a merge event. -#[derive(Debug, Clone, Ord, PartialOrd, Eq, PartialEq, Serialize, Deserialize)] +#[derive(Debug, Clone, Ord, PartialOrd, Eq, PartialEq, Serialize, Deserialize, Columnar)] pub struct BatchEvent { /// Operator identifier. pub operator: usize, @@ -48,7 +49,7 @@ impl From for DifferentialEvent { fn from(e: BatchEvent) -> Self { D /// Either the start or end of a merge event. -#[derive(Debug, Clone, Ord, PartialOrd, Eq, PartialEq, Serialize, Deserialize)] +#[derive(Debug, Clone, Ord, PartialOrd, Eq, PartialEq, Serialize, Deserialize, Columnar)] pub struct BatcherEvent { /// Operator identifier. pub operator: usize, @@ -65,7 +66,7 @@ pub struct BatcherEvent { impl From for DifferentialEvent { fn from(e: BatcherEvent) -> Self { DifferentialEvent::Batcher(e) } } /// Either the start or end of a merge event. -#[derive(Debug, Clone, Ord, PartialOrd, Eq, PartialEq, Serialize, Deserialize)] +#[derive(Debug, Clone, Ord, PartialOrd, Eq, PartialEq, Serialize, Deserialize, Columnar)] pub struct DropEvent { /// Operator identifier. pub operator: usize, @@ -76,7 +77,7 @@ pub struct DropEvent { impl From for DifferentialEvent { fn from(e: DropEvent) -> Self { DifferentialEvent::Drop(e) } } /// Either the start or end of a merge event. -#[derive(Debug, Clone, Ord, PartialOrd, Eq, PartialEq, Serialize, Deserialize)] +#[derive(Debug, Clone, Ord, PartialOrd, Eq, PartialEq, Serialize, Deserialize, Columnar)] pub struct MergeEvent { /// Operator identifier. pub operator: usize, @@ -93,7 +94,7 @@ pub struct MergeEvent { impl From for DifferentialEvent { fn from(e: MergeEvent) -> Self { DifferentialEvent::Merge(e) } } /// A merge failed to complete in time. -#[derive(Debug, Clone, Ord, PartialOrd, Eq, PartialEq, Serialize, Deserialize)] +#[derive(Debug, Clone, Ord, PartialOrd, Eq, PartialEq, Serialize, Deserialize, Columnar)] pub struct MergeShortfall { /// Operator identifier. pub operator: usize, @@ -106,7 +107,7 @@ pub struct MergeShortfall { impl From for DifferentialEvent { fn from(e: MergeShortfall) -> Self { DifferentialEvent::MergeShortfall(e) } } /// Either the start or end of a merge event. -#[derive(Debug, Clone, Ord, PartialOrd, Eq, PartialEq, Serialize, Deserialize)] +#[derive(Debug, Clone, Ord, PartialOrd, Eq, PartialEq, Serialize, Deserialize, Columnar)] pub struct TraceShare { /// Operator identifier. pub operator: usize,