pub fn get_streaming_processor() -> Arc<StreamingProcessor>
Get the global streaming processor instance