builderv2

Dec 30, 2022

Changes in this version

+ var ErrorCreateType = errors.New("create type error")

+ type BufferNullDataPipe struct

+ func (t *BufferNullDataPipe) GetSQLs() (names []string, sqls []string)

+ type ComputeTrace struct

+ func (t *ComputeTrace) GetSQLs() (names []string, sqls []string)

type IStorageCreator

+ GetSQLs func() (names []string, sqls []string)

type Storage

+ func (t *Storage) GetSQLs() ([]string, []string)

Oct 28, 2022

Changes in this version

+ const StorageTypeTraceCal

+ var ErrorStorageType = errors.New("storage type error")

+ type IStorageCreator interface

+ Execute func(string, bool) (string, error)

+ GetDistributedSQL func() (string, bool)

+ GetKafkaEngineSQL func() (string, bool)

+ GetMaterializeViewSQL func() (string, bool)

+ GetMergeTreeSQL func() (string, bool)

+ SetParams func(Params)

+ func GetTableCreator(storageType string) (IStorageCreator, error)

+ type Params struct

+ Cluster string

+ DB *sql.DB

+ Database string

+ IsReplica bool

+ IsShard bool

+ TTL int

+ Table string

+ type Storage struct

+ func (t *Storage) Execute(sql string, isExec bool) (string, error)

+ func (t *Storage) GetDistributedSQL() (string, bool)

+ func (t *Storage) GetKafkaEngineSQL() (string, bool)

+ func (t *Storage) GetMaterializeViewSQL() (string, bool)

+ func (t *Storage) GetMergeTreeSQL() (string, bool)

+ func (t *Storage) SetParams(req Params)

+ type TraceCal struct

+ func (t *TraceCal) GetDistributedSQL() (string, bool)

+ func (t *TraceCal) GetKafkaEngineSQL() (string, bool)

+ func (t *TraceCal) GetMaterializeViewSQL() (string, bool)

+ func (t *TraceCal) GetMergeTreeSQL() (string, bool)