Versions in this module Expand all Collapse all v0 v0.3.0 Jun 14, 2025 Changes in this version + func NewBigQueryDestination(name string, config *config.BaseConfig) (core.Destination, error) + type BigQueryDestination struct + func (b *BigQueryDestination) AlterSchema(ctx context.Context, oldSchema, newSchema *core.Schema) error + func (b *BigQueryDestination) BeginTransaction(ctx context.Context) (core.Transaction, error) + func (b *BigQueryDestination) BulkLoad(ctx context.Context, reader interface{}, format string) error + func (b *BigQueryDestination) Close(ctx context.Context) error + func (b *BigQueryDestination) CreateSchema(ctx context.Context, schema *core.Schema) error + func (b *BigQueryDestination) DropSchema(ctx context.Context, schema *core.Schema) error + func (b *BigQueryDestination) GetStats() *BigQueryStats + func (b *BigQueryDestination) Initialize(ctx context.Context, config *config.BaseConfig) error + func (b *BigQueryDestination) SupportsBatch() bool + func (b *BigQueryDestination) SupportsBulkLoad() bool + func (b *BigQueryDestination) SupportsStreaming() bool + func (b *BigQueryDestination) SupportsTransactions() bool + func (b *BigQueryDestination) SupportsUpsert() bool + func (b *BigQueryDestination) Upsert(ctx context.Context, records []*models.Record, keys []string) error + func (b *BigQueryDestination) Write(ctx context.Context, stream *core.RecordStream) error + func (b *BigQueryDestination) WriteBatch(ctx context.Context, stream *core.BatchStream) error + type BigQueryStats struct + AverageLatency int64 + BatchesProcessed int64 + BytesWritten int64 + ErrorsEncountered int64 + LastBatchTime time.Time + RecordsWritten int64 + StreamingEnabled bool + type RecordBatch struct + BatchID string + Records []*models.Record + Timestamp time.Time
Go to main page