pub fn decode_events(
signature: &str,
data: &RecordBatch,
allow_decode_fail: bool,
filter_by_topic0: bool,
hstack: bool,
) -> Result<RecordBatch>Expand description
Decodes given event data in arrow format to arrow format. Output Arrow schema is auto generated based on the event signature. Handles any level of nesting with Lists/Structs.
When filter_by_topic0 is true, only rows whose topic0 column matches the
event’s selector are decoded. Non-matching rows are silently filtered out.
When hstack is true, the original input columns (after any topic0 filtering)
are appended alongside the decoded columns in the output.
Writes null for data rows that fail to decode if allow_decode_fail is set to true.
Errors when a row fails to decode if allow_decode_fail is set to false.