@@ -140,64 +140,3 @@ impl SchemaProvider for MultiSchemaProvider {
140140 self . children . iter ( ) . any ( |p| p. table_exist ( name) )
141141 }
142142}
143-
144- // TODO merge/rework
145- // #[derive(Debug)]
146- // pub struct SQLTableSource {
147- // provider: Arc<SQLFederationProvider>,
148- // table_name: MultiPartTableReference,
149- // schema: SchemaRef,
150- // }
151-
152- // impl SQLTableSource {
153- // // creates a SQLTableSource and infers the table schema
154- // pub async fn new(
155- // provider: Arc<SQLFederationProvider>,
156- // table_name: impl Into<MultiPartTableReference>,
157- // ) -> Result<Self> {
158- // let table_name = table_name.into();
159- // let schema = Arc::clone(&provider)
160- // .executor
161- // .get_table_schema(table_name.to_string().as_str())
162- // .await?;
163- // Self::new_with_schema(provider, table_name, schema)
164- // }
165-
166- // pub fn new_with_schema(
167- // provider: Arc<SQLFederationProvider>,
168- // table_name: impl Into<MultiPartTableReference>,
169- // schema: SchemaRef,
170- // ) -> Result<Self> {
171- // Ok(Self {
172- // provider,
173- // table_name: table_name.into(),
174- // schema,
175- // })
176- // }
177-
178- // pub fn table_name(&self) -> &MultiPartTableReference {
179- // &self.table_name
180- // }
181- // }
182-
183- // impl FederatedTableSource for SQLTableSource {
184- // fn remote_table_name(&self) -> Option<MultiPartTableReference> {
185- // Some(self.table_name.clone())
186- // }
187-
188- // fn federation_provider(&self) -> Arc<dyn FederationProvider> {
189- // Arc::clone(&self.provider) as Arc<dyn FederationProvider>
190- // }
191- // }
192-
193- // impl TableSource for SQLTableSource {
194- // fn as_any(&self) -> &dyn Any {
195- // self
196- // }
197- // fn schema(&self) -> SchemaRef {
198- // Arc::clone(&self.schema)
199- // }
200- // fn table_type(&self) -> TableType {
201- // TableType::Temporary
202- // }
203- // }
0 commit comments