Versions in this module Expand all Collapse all v0 v0.3.1 Sep 6, 2024 Changes in this version + const ConfigSnowflakeAutoCleanupStage + const ConfigSnowflakeCompression + const ConfigSnowflakeDatabase + const ConfigSnowflakeFileUploadThreads + const ConfigSnowflakeFormat + const ConfigSnowflakeHost + const ConfigSnowflakeKeepAlive + const ConfigSnowflakeNamingPrefix + const ConfigSnowflakePassword + const ConfigSnowflakePort + const ConfigSnowflakePrimaryKey + const ConfigSnowflakeProcessingWorkers + const ConfigSnowflakeSchema + const ConfigSnowflakeStage + const ConfigSnowflakeTable + const ConfigSnowflakeUsername + const ConfigSnowflakeWarehouse + const SnowflakeCSVGoRoutines + const SnowflakeFileUploadThreads + const SnowflakeFormat + const SnowflakeNamingPrefix + const SnowflakePrimaryKey + const SnowflakeStage + func NewDestination() sdk.Destination + type Config struct + AutoCleanupStage bool + Compression string + Database string + FileUploadThreads int + Format string + Host string + KeepAlive bool + NamingPrefix string + Password string + Port int + PrimaryKey string + ProcessingWorkers int + Schema string + Stage string + Username string + Warehouse string + func (Config) Parameters() map[string]config.Parameter + type Destination struct + Config Config + Writer writer.Writer + func (d *Destination) Configure(ctx context.Context, cfg config.Config) error + func (d *Destination) Open(ctx context.Context) error + func (d *Destination) Parameters() config.Parameters + func (d *Destination) Teardown(ctx context.Context) error + func (d *Destination) Write(ctx context.Context, records []opencdc.Record) (int, error)
Go to main page