fn properties( core: &mut StreamSourceCore<impl StateStore>, ) -> StreamExecutorResult<IcebergProperties>