[ https://issues.apache.org/jira/browse/FLINK-32737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Mohsen Rezaei updated FLINK-32737: ---------------------------------- Fix Version/s: 1.17.1 > 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)