tablesplitter

Documentation

Index

• Constants
• func GenerateTableName(originalTableName string, columns []string, splitter string, ...) string
• type Config
• type TableSplitterTransformer
  • func (f *TableSplitterTransformer) Apply(input []abstract.ChangeItem) abstract.TransformerResult
  • func (f *TableSplitterTransformer) Description() string
  • func (f *TableSplitterTransformer) ResultSchema(original *abstract.TableSchema) (*abstract.TableSchema, error)
  • func (f *TableSplitterTransformer) Suitable(table abstract.TableID, schema *abstract.TableSchema) bool
  • func (f *TableSplitterTransformer) Type() abstract.TransformerType

Constants

const (
	Type = abstract.TransformerType("table_splitter_transformer")
)

Functions

func GenerateTableName

func GenerateTableName(originalTableName string, columns []string, splitter string, changeItem *abstract.ChangeItem) string

Types

type Config

type Config struct {
	Tables      filter.Tables `json:"tables,omitempty"`
	Columns     []string      `json:"columns,omitempty"`
	Splitter    string        `json:"splitter,omitempty"`
	UseLegacyLF bool          `json:"useLegacyLf,omitempty"`
}

type TableSplitterTransformer

type TableSplitterTransformer struct {
	Tables      filter.Filter
	Columns     []string
	Splitter    string
	UseLegacyLF bool
	Logger      log.Logger
}

func (*TableSplitterTransformer) Apply

func (f *TableSplitterTransformer) Apply(input []abstract.ChangeItem) abstract.TransformerResult

func (*TableSplitterTransformer) Description

func (f *TableSplitterTransformer) Description() string

func (*TableSplitterTransformer) ResultSchema

func (f *TableSplitterTransformer) ResultSchema(original *abstract.TableSchema) (*abstract.TableSchema, error)

func (*TableSplitterTransformer) Suitable

func (f *TableSplitterTransformer) Suitable(table abstract.TableID, schema *abstract.TableSchema) bool

func (*TableSplitterTransformer) Type

func (f *TableSplitterTransformer) Type() abstract.TransformerType