Struct MuellerStream 

pub struct MuellerStream {

    pub strm_meta: StrmMeta,
    pub id: String,
    pub gender: Option<String>,
    pub age: Option<i32>,
    pub run_id: Option<i32>,
    pub running: Option<bool>,
    pub speed: Option<f32>,
    pub duration: Option<f32>,
    pub distance: Option<f32>,
    pub side: Option<String>,
    pub bout: Option<i32>,
    pub freq: Option<f32>,
    pub walk_ratio: Option<f32>,
    pub start: Option<String>,
    pub end: Option<String>,
    pub time_generated: SystemTime,
}

Fields

strm_meta: StrmMeta

id: String

gender: Option<String>

age: Option<i32>

run_id: Option<i32>

running: Option<bool>

speed: Option<f32>

duration: Option<f32>

distance: Option<f32>

side: Option<String>

bout: Option<i32>

freq: Option<f32>

walk_ratio: Option<f32>

start: Option<String>

end: Option<String>

time_generated: SystemTime

Trait Implementations

impl Anonymizable for MuellerStream

fn quasi_identifiers(&self) -> Vec<QuasiIdentifierTypes>

return the values of the quasi identifiers in the data struct

fn update_quasi_identifiers(&self, qi: Vec<QuasiIdentifierTypes>) -> Self

return a copy of the Anonymizable struct and replace its quasi identifier attributes with given QI’s we return a copy because we want to keep the original intact for new aggregation

fn sensitive_value(&self) -> SensitiveAttribute

return a copy of the sensitive attribute of the struct

fn extract_string_values(&self, _uuid: Uuid, _dr: f64) -> Vec<String>

extract all the values in string format to be used for creating CSV

fn get_timestamp(&self) -> SystemTime

fn calculate_difference(&self, other: &Self) -> f64

compare 2 data points and return the euclidean difference between them

fn calculate_info_loss(&self, other: &Self) -> f64

calculate the info loss between 2 different Anonymizable structs

fn suppress(&self) -> Self

suppress the qi’s based on a buffer of Anonymizables

fn calculate_ordinal_distance( ordinal_x: OrdinalType, ordinal_y: OrdinalType, ) -> f64

calculate the euclidean distance between 2 ordinal data category types TODO: clarify that ranking starts at 1

fn calculate_interval_distance( interval_x: IntervalType, interval_y: IntervalType, ) -> f64

calculate the euclidean distance between 2 interval data types

fn calculate_nominal_distance( nominal_x: NominalType, nominal_y: NominalType, ) -> f64

calculate the euclidean distance between 2 nominal data types

impl Clone for MuellerStream

fn clone(&self) -> MuellerStream

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MuellerStream

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for MuellerStream

fn default() -> MuellerStream

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for MuellerStream

where MuellerStream: Default,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for MuellerStream

fn eq(&self, other: &MuellerStream) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for MuellerStream

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StrmPrivacyValue for MuellerStream

const STRM_SCHEMA_REF: &'static str = "diff_priv/mueller-steps/1.0.0"

const STRM_SCHEMA: &'static str = r#" {"type":"record","name":"MuellerStream","namespace":"diff_priv.MuellerSteps.v1_0_0","fields":[{"name":"strmMeta","type":{"type":"record","name":"strmMeta","namespace":"diff_priv.MuellerSteps.v1_0_0.strmmeta","fields":[{"name":"eventContractRef","type":"string"},{"name":"nonce","type":["null","int"],"default":null},{"name":"timestamp","type":["null","long"],"default":null},{"name":"keyLink","type":["null","string"],"default":null},{"name":"billingId","type":["null","string"],"default":null},{"name":"consentLevels","type":{"type":"array","items":"int"}}]}},{"name":"id","type":"string","doc":"id"},{"name":"gender","type":["null","string"],"doc":"gender of the user","default":null},{"name":"age","type":["null","int"],"doc":"the URL of the current page","default":null},{"name":"run_id","type":["null","int"],"doc":"the id of the run session","default":null},{"name":"running","type":["null","boolean"],"doc":"if the user is running","default":null},{"name":"speed","type":["null","float"],"doc":"the speed of the user","default":null},{"name":"duration","type":["null","float"],"doc":"duration of the step","default":null},{"name":"distance","type":["null","float"],"doc":"distance travaled","default":null},{"name":"side","type":["null","string"],"doc":"which foot","default":null},{"name":"bout","type":["null","int"],"doc":"doc","default":null},{"name":"freq","type":["null","float"],"doc":"which foot","default":null},{"name":"walk_ratio","type":["null","float"],"doc":"which foot","default":null},{"name":"start","type":["null","string"],"doc":"start of step","default":null},{"name":"end","type":["null","string"],"doc":"end of step","default":null}]} "#

fn get_schema(schema: &'static str) -> Schema

fn avro_value(&self) -> Value

impl StructuralPartialEq for MuellerStream