Versions in this module Expand all Collapse all v0 v0.22.0 Aug 9, 2024 Changes in this version type Ingester + func NewIngester(logger log.Logger, table Table) Ingester + type Table interface + InsertRecord func(context.Context, arrow.Record) (tx uint64, err error) + type TableIngester struct + func (ing TableIngester) Ingest(ctx context.Context, record arrow.Record) error v0.21.0 Feb 27, 2024 Changes in this version + type Ingester interface + Close func() error + Ingest func(ctx context.Context, req normalizer.NormalizedWriteRawRequest) error
Go to main page