output

Documentation

Index

• Variables
• type ClickHouse
  • func NewClickHouse(cfg *config.Config, taskCfg *config.TaskConfig) *ClickHouse
  • func (c *ClickHouse) ChangeSchema(newKeys *sync.Map) (err error)
  • func (c *ClickHouse) Drain()
  • func (c *ClickHouse) Init() (err error)
  • func (c *ClickHouse) Send(batch *model.Batch)

Variables

var (
	ErrTblNotExist = errors.Newf("table doesn't exist")
)

Types

type ClickHouse

type ClickHouse struct {
	Dims     []*model.ColumnWithType
	IdxSerID int
	NameKey  string
	// contains filtered or unexported fields
}

ClickHouse is an output service consumers from kafka messages

func NewClickHouse

func NewClickHouse(cfg *config.Config, taskCfg *config.TaskConfig) *ClickHouse

NewClickHouse new a clickhouse instance

func (*ClickHouse) ChangeSchema

func (c *ClickHouse) ChangeSchema(newKeys *sync.Map) (err error)

func (*ClickHouse) Drain

func (c *ClickHouse) Drain()

Drain drains flying batchs

func (*ClickHouse) Init

func (c *ClickHouse) Init() (err error)

Init the clickhouse intance

func (*ClickHouse) Send

func (c *ClickHouse) Send(batch *model.Batch)

Send a batch to clickhouse