Module handler 

Structs

AnalyticsHandler

Generic wrapper that implements Handler for any Processor with analytics batching.

Batch

Batch of rows grouped by checkpoint, ready for commit. Non-generic: conversion to trait objects happens in batch(), not commit().

CheckpointRows

Rows from a single checkpoint with metadata.

Traits

Row

Row types implement this to provide epoch and checkpoint information for batching. Batches are committed at epoch boundaries to ensure files don’t span epochs.