From 7c9fc39b8d9e4b52561cf5f70c6a291487c566eb Mon Sep 17 00:00:00 2001 From: Andrew Lamb Date: Thu, 9 Jan 2025 16:42:31 -0500 Subject: [PATCH] minor: Add link to example in catalog --- datafusion/catalog/src/async.rs | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/datafusion/catalog/src/async.rs b/datafusion/catalog/src/async.rs index 504f20ff9543..a244261b91e2 100644 --- a/datafusion/catalog/src/async.rs +++ b/datafusion/catalog/src/async.rs @@ -190,6 +190,10 @@ impl CatalogProviderList for ResolvedCatalogProviderList { /// After implementing this trait you can call the [`AsyncSchemaProvider::resolve`] method to get an /// `Arc` that contains a cached copy of the referenced tables. The `resolve` /// method can be slow and asynchronous as it is only called once, before planning. +/// +/// See the [remote_catalog.rs] for an end to end example +/// +/// [remote_catalog.rs]: https://github.com/apache/datafusion/blob/main/datafusion-examples/examples/remote_catalog.rs #[async_trait] pub trait AsyncSchemaProvider: Send + Sync { /// Lookup a table in the schema provider @@ -202,6 +206,8 @@ pub trait AsyncSchemaProvider: Send + Sync { /// /// This cache is intended to be short-lived for the execution of a single query. There is no mechanism /// for refresh or eviction of stale entries. + /// + /// See the [`AsyncSchemaProvider`] documentation for additional details async fn resolve( &self, references: &[TableReference],