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.