declarative_dataflow/
logging.rs

1//! Loggers and logging events for declarative dataflow.
2
3/// Logger for differential dataflow events.
4pub type Logger = ::timely::logging::Logger<DeclarativeEvent>;
5
6/// Possible different declarative events.
7#[derive(Debug, Clone, Serialize, Ord, PartialOrd, Eq, PartialEq)]
8pub enum DeclarativeEvent {
9    /// Tuples materialized during a join.
10    JoinTuples(JoinTuplesEvent),
11}
12
13/// Tuples materialized during a join.
14#[derive(Debug, Clone, Serialize, Ord, PartialOrd, Eq, PartialEq)]
15pub struct JoinTuplesEvent {
16    /// How many tuples.
17    pub cardinality: i64,
18}
19
20impl From<JoinTuplesEvent> for DeclarativeEvent {
21    fn from(e: JoinTuplesEvent) -> Self {
22        DeclarativeEvent::JoinTuples(e)
23    }
24}