Skip to main content

streams

harmos_runtime::storage::writes::convert

Function streams 

Source 
pub fn streams(
    scope: Option<&Identifier>,
    batch: &DecodedBatch,
    schema: &Schema,
) -> Result<Vec<StreamInput>, Error>