event_cache_data_object

Silver MNO Event data module with flags computed in Semantic Checks

EventCacheDataObject

Bases: SilverEventFlaggedDataObject

Class that models the cleaned MNO Event data, with flags computed in the semantic checks module.

Source code in multimno/core/data_objects/silver/event_cache_data_object.py

class EventCacheDataObject(SilverEventFlaggedDataObject):
    """
    Class that models the cleaned MNO Event data, with flags computed
    in the semantic checks module.
    """

    ID = "EventCacheDO"

    # SCHEMA and partition columns depend on the semantic event data
    SCHEMA = StructType(
        SilverEventFlaggedDataObject.SCHEMA.fields
        + [StructField(ColNames.is_last_event, BooleanType(), nullable=False)]
    )

    PARTITION_COLUMNS = SilverEventFlaggedDataObject.PARTITION_COLUMNS + [ColNames.is_last_event]