Documentation
¶
Index ¶
- type RecordTransformer
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
Source Files
Click to show internal directories.
Click to hide internal directories.