| Interface | Description |
|---|---|
| SnowflakeIO.CsvMapper<T> |
Interface for user-defined function mapping parts of CSV line into T.
|
| SnowflakeIO.UserDataMapper<T> |
Interface for user-defined function mapping T into array of Objects.
|
| SnowflakePipelineOptions |
| 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.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.Write<T> |
Implementation of
SnowflakeIO.write(). |