Input/Output¶

Classes

`DataFrameReader`(session)	Provides methods to load data in various supported formats from a Snowflake stage to a `DataFrame`.
`DataFrameWriter`(dataframe)	Provides methods for writing data from a `DataFrame` to supported output destinations.
`FileOperation`(session)	Provides methods for working on files in a stage.
`PutResult`(source, target, source_size, ...)	Represents the results of uploading a local file to a stage location.
`GetResult`(file, size, status, message)	Represents the results of downloading a file from a stage location to the local file system.

Methods

`DataFrameReader.avro`(path)	Specify the path of the AVRO file(s) to load.
`DataFrameReader.csv`(path)	Specify the path of the CSV file(s) to load.
`DataFrameReader.json`(path)	Specify the path of the JSON file(s) to load.
`DataFrameReader.option`(key, value)	Sets the specified option in the DataFrameReader.
`DataFrameReader.options`(configs)	Sets multiple specified options in the DataFrameReader.
`DataFrameReader.orc`(path)	Specify the path of the ORC file(s) to load.
`DataFrameReader.parquet`(path)	Specify the path of the PARQUET file(s) to load.
`DataFrameReader.schema`(schema)	Define the schema for CSV files that you want to read.
`DataFrameReader.table`(name)	Returns a Table that points to the specified table.
`DataFrameReader.with_metadata`(*metadata_cols)	Define the metadata columns that need to be selected from stage files.
`DataFrameReader.xml`(path)	Specify the path of the XML file(s) to load.
`DataFrameWriter.copy_into_location`()	Executes a COPY INTO <location> to unload data from a `DataFrame` into one or more files in a stage or external stage.
`DataFrameWriter.mode`(save_mode)	Set the save mode of this `DataFrameWriter`.
`DataFrameWriter.saveAsTable`(table_name, *[, ...])	Writes the data to the specified table in a Snowflake database.
`DataFrameWriter.save_as_table`()	Writes the data to the specified table in a Snowflake database.
`FileOperation.get`(stage_location, ...[, ...])	Downloads the specified files from a path in a stage to a local directory.
`FileOperation.get_stream`(stage_location, *)	Downloads the specified files from a path in a stage and expose it through a stream.
`FileOperation.put`(local_file_name, ...[, ...])	Uploads local files to the stage.
`FileOperation.put_stream`(input_stream, ...)	Uploads local files to the stage via a file stream.
`PutResult.count`(value, /)	Return number of occurrences of value.
`PutResult.index`(value[, start, stop])	Return first index of value.
`GetResult.count`(value, /)	Return number of occurrences of value.
`GetResult.index`(value[, start, stop])	Return first index of value.

Attributes

`PutResult.message`	The detailed message of the upload status.
`PutResult.source`	The source file path.
`PutResult.source_compression`	The source file compression format.
`PutResult.source_size`	The size in bytes of the source file.
`PutResult.status`	Status indicating whether the file was uploaded to the stage.
`PutResult.target`	The file path in the stage where the source file is uploaded.
`PutResult.target_compression`	The target file compression format.
`PutResult.target_size`	The size in bytes of the target file.
`GetResult.file`	The downloaded file path.
`GetResult.message`	The detailed message about the download status.
`GetResult.size`	The size in bytes of the downloaded file.
`GetResult.status`	Indicates whether the download is successful.