[
https://issues.apache.org/jira/browse/FLINK-32737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mohsen Rezaei resolved FLINK-32737.
-----------------------------------
Resolution: Fixed
> Add support for Snowflake sink connector
> ----------------------------------------
>
> Key: FLINK-32737
> URL: https://issues.apache.org/jira/browse/FLINK-32737
> Project: Flink
> Issue Type: New Feature
> Components: Connectors / JDBC
> Reporter: Mohsen Rezaei
> Priority: Major
> Fix For: 1.17.1
>
>
> Implement a sink connector to allow for loading pre-processed data into
> Snowflake. In the streaming world, this can make use of the [Snowpipe
> Streaming
> API|https://javadoc.io/doc/net.snowflake/snowflake-ingest-sdk/2.0.2/net/snowflake/ingest/streaming/package-summary.html]
> and potentially in a future version support the exactly-once semantics.
> This sink would use the latest unified sink interfaces to implement
> at-least-once as a first step, providing {{DeliveryGuarantee.NONE}} and
> {{DeliveryGuarantee.AT_LEAST_ONCE}} semantics. A user would be able to
> provide a custom serializer for going from {{InputT}} incoming type to
> {{Map<String, Object>}} as documented by Snowflake, and configure the sink
> using a builder pattern.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
