fn resolve_pk_info( input_schema: &Schema, log_store_table: &Table, ) -> StreamResult<&'static KvLogStorePkInfo>