Description
Creating java Snowflake connector which includes:
- batch processing connector provided by COPY operation from SnowflakeJDBC which will load/unload files staged on GCP,
- streaming processing thanks to SnowPipe mechanism and Snowflake Ingest Java library,
- Snowflake authentication mechanism.
Attachments
Issue Links
- fixes
-
BEAM-9466 SnowflakeIO in python
- Resolved
- is a parent of
-
BEAM-9894 Add batch SnowflakeIO.Write to Java SDK
- Resolved
-
BEAM-10331 Add SnowflakeIO to list of built-in IOs
- Resolved
-
BEAM-9722 Add batch SnowflakeIO.Read to Java SDK
- Triage Needed
-
BEAM-9896 Add streaming for SnowflakeIO.Write to Java SDK
- Triage Needed
-
BEAM-10343 Add dispositions for SnowflakeIO.write
- Triage Needed
-
BEAM-9897 Add cross-language support to SnowflakeIO.Read
- Triage Needed
-
BEAM-9898 Add cross-language support to SnowflakeIO.Write
- Triage Needed
-
BEAM-10669 Add support for Dataflow Templates
- Resolved
-
BEAM-9895 Add integration test for batch SnowflakeIO Read and Write for Java SDK
- Resolved
-
BEAM-10685 Add SnowflakeIO Streaming integration test
- Resolved
-
BEAM-9899 Add integration tests for cross-language SnowflakeIO Read and Write
- Resolved