chload

Documentation

Index

• type CHLoad
  • func New(chConn chutils.CHConnector, gzipCompressionLevel config.GzipComprLevel) *CHLoad
  • func (c *CHLoad) Exec(query string) error
  • func (c *CHLoad) Flush(tableName config.ChTableName, columns []string) error
  • func (c *CHLoad) Query(query string) ([][]string, error)
  • func (c *CHLoad) Write(p []byte) (int, error)
  • func (c *CHLoad) WriteByte(p byte) error
• type CHLoader

Types

type CHLoad

type CHLoad struct {
	// contains filtered or unexported fields
}

func New

func New(chConn chutils.CHConnector, gzipCompressionLevel config.GzipComprLevel) *CHLoad

func (*CHLoad) Exec

func (c *CHLoad) Exec(query string) error

func (*CHLoad) Flush

func (c *CHLoad) Flush(tableName config.ChTableName, columns []string) error

func (*CHLoad) Query

func (c *CHLoad) Query(query string) ([][]string, error)

func (*CHLoad) Write

func (c *CHLoad) Write(p []byte) (int, error)

func (*CHLoad) WriteByte

func (c *CHLoad) WriteByte(p byte) error

type CHLoader

type CHLoader interface {
	utils.Writer

	Flush(tableName config.ChTableName, columns []string) error
	Exec(string) error
	Query(string) ([][]string, error)
}