datafusion.input#

This package provides for input sources.

The primary class used within DataFusion is LocationInputPlugin.

Submodules#

Classes#

LocationInputPlugin

Input Plugin for everything.

Package Contents#

class datafusion.input.LocationInputPlugin#

Bases: datafusion.input.base.BaseInputSource

Input Plugin for everything.

This can be read in from a file (on disk, remote etc.).

build_table(input_item: str, table_name: str, **kwargs: Any) datafusion.common.SqlTable#

Create a table from the input source.

is_correct_input(input_item: Any, table_name: str, **kwargs: Any) bool#

Returns True if the input is valid.