datafusion.input.base¶
This module provides BaseInputSource.
A user can extend this to provide a custom input source.
Classes¶
Base Input Source class. |
Module Contents¶
- class datafusion.input.base.BaseInputSource¶
Bases:
abc.ABCBase Input Source class.
If a consuming library would like to provider their own InputSource this is the class they should extend to write their own.
Once completed the Plugin InputSource can be registered with the SessionContext to ensure that it will be used in order to obtain the SqlTable information from the custom datasource.
- abstract build_table(input_item: Any, table_name: str, **kwarg) datafusion.common.SqlTable¶
Create a table from the input source.
- abstract is_correct_input(input_item: Any, table_name: str, **kwargs) bool¶
Returns True if the input is valid.