Package org.apache.beam.sdk.io.snowflake

package org.apache.beam.sdk.io.snowflake

Snowflake IO transforms.

Related Packages

Package	Description
org.apache.beam.sdk.io	Defines transforms for reading and writing common storage formats, including invalid reference org.apache.beam.sdk.io.AvroIO , and TextIO.
org.apache.beam.sdk.io.snowflake.crosslanguage	Cross-language for SnowflakeIO.
org.apache.beam.sdk.io.snowflake.data	Snowflake IO data types.
org.apache.beam.sdk.io.snowflake.enums	Snowflake IO data types.
org.apache.beam.sdk.io.snowflake.services	Snowflake IO services and POJOs.

Class	Description
KeyPairUtils
SnowflakeIO	IO to read and write data on Snowflake.
SnowflakeIO.Concatenate	Combines list of String to provide one String with paths where files were staged for write.
SnowflakeIO.CsvMapper<T>	Interface for user-defined function mapping parts of CSV line into T.
SnowflakeIO.DataSourceConfiguration	A POJO describing a DataSource, providing all properties allowing to create a DataSource.
SnowflakeIO.DataSourceProviderFromDataSourceConfiguration	Wraps SnowflakeIO.DataSourceConfiguration to provide DataSource.
SnowflakeIO.Read<T>	Implementation of SnowflakeIO.read().
SnowflakeIO.Read.CleanTmpFilesFromGcsFn	Removes temporary staged files after reading.
SnowflakeIO.Read.MapCsvToStringArrayFn	Parses String from incoming data in PCollection to have proper format for CSV files.
SnowflakeIO.UserDataMapper<T>	Interface for user-defined function mapping T into array of Objects.
SnowflakeIO.Write<T>	Implementation of SnowflakeIO.write().
SnowflakePipelineOptions