Struct DataFrameReader 

pub struct DataFrameReader { /* private fields */ }

DataFrameReader for reading data from various sources.

Mirrors pyspark.sql.connect.readwriter.DataFrameReader.

Implementations

impl DataFrameReader

pub fn format(self, source: &str) -> DataFrameReader

Set the format/source type (e.g., “json”, “parquet”, “csv”).

pub fn schema(self, schema: String) -> DataFrameReader

Set the schema from a DDL string or JSON string.

pub fn option(self, key: &str, value: &str) -> DataFrameReader

Set a single option key-value pair.

pub fn options(self, options: HashMap<String, String>) -> DataFrameReader

Set multiple options.

pub fn load(self, path: Option<&str>) -> DataFrame

Load data from the specified path(s) with the configured format, schema, and options.

pub fn changes(self, table_name: &str) -> DataFrame

Read the CDC changes of a named table. Mirrors DataFrameReader.changes.

pub fn table(self, table_name: &str) -> DataFrame

Read from a named table.

pub fn json(self, path: &str) -> DataFrame

Read JSON data.

pub fn parquet(self, path: &str) -> DataFrame

Read Parquet data.

pub fn csv(self, path: &str) -> DataFrame

Read CSV data.

pub fn orc(self, path: &str) -> DataFrame

Read ORC data.

pub fn text(self, path: &str) -> DataFrame

Read text data.

pub fn xml(self, path: &str) -> DataFrame

Read XML file(s). Mirrors DataFrameReader.xml.

pub fn jdbc( self, url: &str, table: &str, predicates: Option<Vec<String>>, ) -> DataFrame

Read from JDBC data source.