[
https://issues.apache.org/jira/browse/FLINK-32737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mohsen Rezaei updated FLINK-32737:
----------------------------------
Description:
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.
For the first version, as a user, I'd like to be able to sink data into a
user-configurable Snowflake sink connector. 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.
was: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 and support the exactly-once semantics.
> 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
>
> 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.
> For the first version, as a user, I'd like to be able to sink data into a
> user-configurable Snowflake sink connector. 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.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
