async fn create_and_validate_table_impl( config: &IcebergConfig, param: &SinkParam, ) -> Result<Table>