This is an automated email from the ASF dual-hosted git repository.
alamb pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/datafusion.git
The following commit(s) were added to refs/heads/main by this push:
new b89037f0d4 Add references to github issue (#11784)
b89037f0d4 is described below
commit b89037f0d4924f42712d9940dfa3fc5a66903f89
Author: Piotr Findeisen <[email protected]>
AuthorDate: Fri Aug 2 20:05:37 2024 +0200
Add references to github issue (#11784)
---
datafusion/core/src/datasource/listing/table.rs | 4 ++--
datafusion/core/src/datasource/listing_table_factory.rs | 2 +-
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/datafusion/core/src/datasource/listing/table.rs
b/datafusion/core/src/datasource/listing/table.rs
index 72c6e0d84c..80f49e4eb8 100644
--- a/datafusion/core/src/datasource/listing/table.rs
+++ b/datafusion/core/src/datasource/listing/table.rs
@@ -743,7 +743,7 @@ impl TableProvider for ListingTable {
filters: &[Expr],
limit: Option<usize>,
) -> Result<Arc<dyn ExecutionPlan>> {
- // TODO remove downcast_ref from here?
+ // TODO (https://github.com/apache/datafusion/issues/11600) remove
downcast_ref from here?
let session_state =
state.as_any().downcast_ref::<SessionState>().unwrap();
let (mut partitioned_file_lists, statistics) = self
.list_files_for_scan(session_state, filters, limit)
@@ -883,7 +883,7 @@ impl TableProvider for ListingTable {
// Get the object store for the table path.
let store = state.runtime_env().object_store(table_path)?;
- // TODO remove downcast_ref from here?
+ // TODO (https://github.com/apache/datafusion/issues/11600) remove
downcast_ref from here?
let session_state =
state.as_any().downcast_ref::<SessionState>().unwrap();
let file_list_stream = pruned_partition_list(
session_state,
diff --git a/datafusion/core/src/datasource/listing_table_factory.rs
b/datafusion/core/src/datasource/listing_table_factory.rs
index ce52dd9816..591a19aab4 100644
--- a/datafusion/core/src/datasource/listing_table_factory.rs
+++ b/datafusion/core/src/datasource/listing_table_factory.rs
@@ -52,7 +52,7 @@ impl TableProviderFactory for ListingTableFactory {
state: &dyn Session,
cmd: &CreateExternalTable,
) -> Result<Arc<dyn TableProvider>> {
- // TODO remove downcast_ref from here. Should file format factory be
an extension to session state?
+ // TODO (https://github.com/apache/datafusion/issues/11600) remove
downcast_ref from here. Should file format factory be an extension to session
state?
let session_state =
state.as_any().downcast_ref::<SessionState>().unwrap();
let file_format = session_state
.get_file_format_factory(cmd.file_type.as_str())
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
