ytdict

Documentation

Index

• Constants
• type Config
• type YtDictTransformer
  • func NewYtDictTransformer(cfg Config, lgr log.Logger) (*YtDictTransformer, error)
  • func (t *YtDictTransformer) Apply(input []abstract.ChangeItem) abstract.TransformerResult
  • func (t *YtDictTransformer) Description() string
  • func (t *YtDictTransformer) ResultSchema(original *abstract.TableSchema) (*abstract.TableSchema, error)
  • func (t *YtDictTransformer) Suitable(table abstract.TableID, schema *abstract.TableSchema) bool
  • func (t *YtDictTransformer) Type() abstract.TransformerType

Constants

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

Types

type Config

type Config struct {
	Tables filter.Tables `json:"tables"`
}

type YtDictTransformer

type YtDictTransformer struct {
	Tables filter.Filter
	Logger log.Logger
}

func NewYtDictTransformer

func NewYtDictTransformer(cfg Config, lgr log.Logger) (*YtDictTransformer, error)

func (*YtDictTransformer) Apply

func (t *YtDictTransformer) Apply(input []abstract.ChangeItem) abstract.TransformerResult

func (*YtDictTransformer) Description

func (t *YtDictTransformer) Description() string

func (*YtDictTransformer) ResultSchema

func (t *YtDictTransformer) ResultSchema(original *abstract.TableSchema) (*abstract.TableSchema, error)

func (*YtDictTransformer) Suitable

func (t *YtDictTransformer) Suitable(table abstract.TableID, schema *abstract.TableSchema) bool

func (*YtDictTransformer) Type

func (t *YtDictTransformer) Type() abstract.TransformerType