fn streaming_context(
receiver: InputReceiver,
schema: SchemaRef,
table_name: &str,
) -> Result<SessionContext, ReadStatError>fn streaming_context(
receiver: InputReceiver,
schema: SchemaRef,
table_name: &str,
) -> Result<SessionContext, ReadStatError>