Flow Snowflake CDC Source Connector

This is a connector which captures changes to Snowflake tables.

It does this using streams, by periodically copying all new changes (from the stream corresponding to a particular source table) into a connector-managed staging table and then capturing the contents of that staging table into Flow.

Useful commands:

$ docker build -t ghcr.io/estuary/source-snowflake:local -f source-snowflake/Dockerfile .
$ flowctl raw discover --source acmeCo/flow.yaml
$ flowctl raw capture acmeCo/flow.yaml