bulkupload

Documentation

Index

• func DecodeCopyToTuples(colBuf *bytes.Buffer, out utils.Writer, pgColumns map[int]*config.PgColumn, ...) error
• type BulkUpload
  • func New(chConn chutils.CHConnector, gzipBufSize int, comprLevel config.GzipComprLevel) *BulkUpload
  • func (c *BulkUpload) BulkUpload(tableName config.ChTableName, columns []string) error
  • func (c *BulkUpload) Finish() error
  • func (c *BulkUpload) Init(buf buffer.BufferAt) error
  • func (c *BulkUpload) Write(p []byte) (int, error)
  • func (c *BulkUpload) WriteByte(p byte) error
• type BulkUploader

Functions

func DecodeCopyToTuples

func DecodeCopyToTuples(colBuf *bytes.Buffer, out utils.Writer, pgColumns map[int]*config.PgColumn, colProps map[int]*config.ColumnProperty, in []byte) error

DecodeCopyToTuples decodes line from the text pg copy command into a array of tuples

Types

type BulkUpload

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

func New

func New(chConn chutils.CHConnector, gzipBufSize int, comprLevel config.GzipComprLevel) *BulkUpload

func (*BulkUpload) BulkUpload

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

func (*BulkUpload) Finish

func (c *BulkUpload) Finish() error

func (*BulkUpload) Init

func (c *BulkUpload) Init(buf buffer.BufferAt) error

Prepare pipes

func (*BulkUpload) Write

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

func (*BulkUpload) WriteByte

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

type BulkUploader

type BulkUploader interface {
	utils.Writer

	Init(buffer.BufferAt) error
	Finish() error
	BulkUpload(name config.ChTableName, columns []string) error
}