Skip to content

Releases: snowflakedb/spark-snowflake

v.2.3.2

06 Apr 05:34
Compare
Choose a tag to compare
  • Support for Spark 2.3.
  • truncate_columns can be passed along with other parameters for use in the COPY Dataframe write to Snowflake.
    If set to true, TRUCATECOLUMNS will be true in the load statement.
  • Support for column-mapping. Columns may be written out-of-order, or to an arbitrary set of equal quantity, type-compatible columns from a Dataframe to a Snowflake table. Example:
    df.write.format(SNOWFLAKE_SOURCE_NAME).options(connectorOptionsNoTable)
      .option("dbtable", dbtable)
      .option("columnmap", Map("one" -> "sf_col2", "two" -> "sf_col1").toString())
      .mode(SaveMode.Append).save()

will write column "one" of the Spark Dataframe to a "sf_col2" and a column "two" of the Dataframe to a "sf_col1" in the target Snowflake table.

v.2.3.1

23 Mar 07:08
Compare
Choose a tag to compare
  • Full pushdowns are automatically enabled.

v2.3.0

16 Feb 07:23
Compare
Choose a tag to compare
  • Updated main branch to support Spark 2.2, and LT-support branch to support Spark 2.1.
  • Utils.runQuery() now supports a java.util.Map options map.

v2.2.8

30 Nov 00:32
Compare
Choose a tag to compare

Added a new optional parameter, parallelism, to control the size of the thread pool used in uploads and downloads.

Example:

df.write
.format(SNOWFLAKE_SOURCE_NAME)
.option("parallelism", "12")
.mode(SaveMode.Overwrite)
.save()

v2.2.7

02 Oct 21:50
Compare
Choose a tag to compare
  • We now enforce a tighter version dependency on snowflake-jdbc, as specified in the project definition.
  • The connector no longer uses disallowed prepared statements for DDL via JDBC.

v2.2.6

14 Sep 21:42
Compare
Choose a tag to compare
  • Fixed a regression (NoSuchMethodException) when using the internal temp-stage with newer versions of JDBC. The new minimum version of JDBC, to be used with versions 2.2.6+ of the connector, is 3.2.4.

v2.2.4

01 Aug 22:06
Compare
Choose a tag to compare
  • Changed SnowflakeRelation and MergedParameters printout.

v2.2.3

29 Jun 18:42
Compare
Choose a tag to compare
  • Fixed an issue where DDLs with identifiers using one or more of the reserved SQL keywords (ORDER, SELECT, etc.) would fail.

  • Fixed an issue when returning empty-string results with non-nullable columns.

v2.2.2

18 May 18:15
Compare
Choose a tag to compare
  • Fixed an issue with identifier quoting for quoted column names for filter pushdowns.

v2.2.1

05 May 19:12
Compare
Choose a tag to compare
  • Fixed an issue when loading empty result sets from Snowflake.