Skip to main content

extract_max_event_time

Function extract_max_event_time 

Source
pub fn extract_max_event_time(
    batch: &RecordBatch,
    field: &str,
) -> Result<Option<i64>, ConnectorError>
Expand description

Max event time (epoch ms) from a named Timestamp(_) column. Ok(None) when every row is null.

§Errors

SchemaMismatch if field is missing or isn’t a Timestamp(_).