Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClickHouse ¶
type ClickHouse struct { Dims []*model.ColumnWithType Dms []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 ¶ added in v1.5.2
func (c *ClickHouse) ChangeSchema(newKeys *sync.Map) (err error)
func (*ClickHouse) Send ¶ added in v1.5.2
func (c *ClickHouse) Send(batch *model.Batch)
Send a batch to clickhouse
Click to show internal directories.
Click to hide internal directories.