@@ -73,7 +73,7 @@ def with_create_default_catalog_and_schema(
73
73
def with_default_catalog_and_schema (
74
74
self , catalog : str , schema : str
75
75
) -> SessionConfig :
76
- """Select a name for the default catalog and shcema .
76
+ """Select a name for the default catalog and schema .
77
77
78
78
Args:
79
79
catalog: Catalog name.
@@ -517,7 +517,7 @@ def sql(self, query: str, options: SQLOptions | None = None) -> DataFrame:
517
517
def sql_with_options (self , query : str , options : SQLOptions ) -> DataFrame :
518
518
"""Create a :py:class:`~datafusion.dataframe.DataFrame` from SQL query text.
519
519
520
- This function will first validating that the query is allowed by the
520
+ This function will first validate that the query is allowed by the
521
521
provided options.
522
522
523
523
Args:
@@ -636,12 +636,14 @@ def from_polars(self, data: polars.DataFrame, name: str | None = None) -> DataFr
636
636
"""
637
637
return DataFrame (self .ctx .from_polars (data , name ))
638
638
639
- def register_table (self , name : str , table : pyarrow .Table ) -> None :
640
- """Register a table with the given name into the session.
639
+ def register_table (self , name : str , table : Table ) -> None :
640
+ """Register a :py:class: `~datafusion.catalog.Table` as a table.
641
+
642
+ The registered table can be referenced from SQL statement executed against.
641
643
642
644
Args:
643
645
name: Name of the resultant table.
644
- table: PyArrow table to add to the session context.
646
+ table: DataFusion table to add to the session context.
645
647
"""
646
648
self .ctx .register_table (name , table )
647
649
0 commit comments