transformer

Documentation

Index

• type RecordTransformer
  • func NewRecordTransformer(opts ...RecordTransformerOption) *RecordTransformer
  • func (t *RecordTransformer) Transform(record arrow.Record) arrow.Record
  • func (t *RecordTransformer) TransformSchema(sc *arrow.Schema) *arrow.Schema
• type RecordTransformerOption
  • func WithCQColumnsNotNull() RecordTransformerOption
  • func WithCQIDPrimaryKey() RecordTransformerOption
  • func WithRemovePKs() RecordTransformerOption
  • func WithRemoveUniqueConstraints() RecordTransformerOption
  • func WithSourceNameColumn(name string) RecordTransformerOption
  • func WithSyncGroupIdColumn(syncGroupId string) RecordTransformerOption
  • func WithSyncTimeColumn(t time.Time) RecordTransformerOption

Types

type RecordTransformer

type RecordTransformer struct {
	// contains filtered or unexported fields
}

func NewRecordTransformer

func NewRecordTransformer(opts ...RecordTransformerOption) *RecordTransformer

func (*RecordTransformer) Transform

func (t *RecordTransformer) Transform(record arrow.Record) arrow.Record

func (*RecordTransformer) TransformSchema

func (t *RecordTransformer) TransformSchema(sc *arrow.Schema) *arrow.Schema

type RecordTransformerOption

type RecordTransformerOption func(*RecordTransformer)

func WithCQColumnsNotNull

func WithCQColumnsNotNull() RecordTransformerOption

func WithCQIDPrimaryKey

func WithCQIDPrimaryKey() RecordTransformerOption

func WithRemovePKs

func WithRemovePKs() RecordTransformerOption

func WithRemoveUniqueConstraints

func WithRemoveUniqueConstraints() RecordTransformerOption

func WithSourceNameColumn

func WithSourceNameColumn(name string) RecordTransformerOption

func WithSyncGroupIdColumn

func WithSyncGroupIdColumn(syncGroupId string) RecordTransformerOption

func WithSyncTimeColumn

func WithSyncTimeColumn(t time.Time) RecordTransformerOption