1use arrow_data::ArrayData;
2
3use crate::prelude::*;
4
5use uhlc::Timestamp;
6
7#[derive(Debug, PartialEq, Clone)]
8pub struct Header {
9 pub timestamp: Timestamp,
10}
11
12#[derive(Debug, PartialEq, Clone)]
13pub struct DataflowMessage {
14 pub header: Header,
15 pub data: ArrayData,
16}