dao

Documentation

Index

• Constants
• func ColumnValues(columns []*sql.ColumnType) []interface{}
• func Md5(msg string) string
• func ParseColumnValues(value interface{}) interface{}
• type DaoConfig
• type FeatureViewDao
  • func NewFeatureViewDao(config DaoConfig) FeatureViewDao
• type FeatureViewFeatureDBDao
  • func NewFeatureViewFeatureDBDao(config DaoConfig) *FeatureViewFeatureDBDao
  • func (d *FeatureViewFeatureDBDao) GetFeatures(keys []interface{}, selectFields []string) ([]map[string]interface{}, error)
  • func (d *FeatureViewFeatureDBDao) GetUserSequenceFeature(keys []interface{}, userIdField string, ...) ([]map[string]interface{}, error)
• type FeatureViewHologresDao
  • func NewFeatureViewHologresDao(config DaoConfig) *FeatureViewHologresDao
  • func (d *FeatureViewHologresDao) GetFeatures(keys []interface{}, selectFields []string) ([]map[string]interface{}, error)
  • func (d *FeatureViewHologresDao) GetUserSequenceFeature(keys []interface{}, userIdField string, ...) ([]map[string]interface{}, error)
• type FeatureViewIGraphDao
  • func NewFeatureViewIGraphDao(config DaoConfig) *FeatureViewIGraphDao
  • func (d *FeatureViewIGraphDao) GetFeatures(keys []interface{}, selectFields []string) ([]map[string]interface{}, error)
  • func (d *FeatureViewIGraphDao) GetUserSequenceFeature(keys []interface{}, userIdField string, ...) ([]map[string]interface{}, error)
• type FeatureViewMysqlDao
  • func NewFeatureViewMysqlDao(config DaoConfig) *FeatureViewMysqlDao
  • func (d *FeatureViewMysqlDao) GetFeatures(keys []interface{}, selectFields []string) ([]map[string]interface{}, error)
  • func (d *FeatureViewMysqlDao) GetUserSequenceFeature(keys []interface{}, userIdField string, ...) ([]map[string]interface{}, error)
• type FeatureViewRedisDao
  • func NewFeatureViewRedisDao(config DaoConfig) *FeatureViewRedisDao
  • func (d *FeatureViewRedisDao) GetFeatures(keys []interface{}, selectFields []string) ([]map[string]interface{}, error)
  • func (d *FeatureViewRedisDao) GetUserSequenceFeature(keys []interface{}, userIdField string, ...) ([]map[string]interface{}, error)
• type FeatureViewTableStoreDao
  • func NewFeatureViewTableStoreDao(config DaoConfig) *FeatureViewTableStoreDao
  • func (d *FeatureViewTableStoreDao) GetFeatures(keys []interface{}, selectFields []string) ([]map[string]interface{}, error)
  • func (d *FeatureViewTableStoreDao) GetUserSequenceFeature(keys []interface{}, userIdField string, ...) ([]map[string]interface{}, error)

Constants

const (
	FeatureDB_Protocal_Version_F    = byte('F')
	FeatureDB_IfNull_Flag_Version_1 = byte('1')
)

Functions

func ColumnValues

func ColumnValues(columns []*sql.ColumnType) []interface{}

ColumnValues return dynamic column values by the sql.ColumnType

func Md5

func Md5(msg string) string

func ParseColumnValues

func ParseColumnValues(value interface{}) interface{}

ParseColumnValues return true value of column value. Retrun nil if the column value is not valid, like nullable.

Types

type DaoConfig

type DaoConfig struct {
	DatasourceType      string
	RedisName           string
	RedisPrefix         string
	RedisDefaultKey     string
	RedisValueDelimeter string
	MysqlName           string
	MysqlTableName      string
	Config              string
	HBasePrefix         string
	HBaseName           string
	HBaseTable          string
	ColumnFamily        string
	Qualifier           string

	PrimaryKeyField string
	EventTimeField  string
	TTL             int

	// hologres
	HologresName      string
	HologresTableName string

	//tablestore
	TableStoreName      string
	TableStoreTableName string

	// clickhouse
	ClickHouseName      string
	ClickHouseTableName string

	// be engine
	BeName               string
	BizName              string
	BeTableName          string
	BeExposureUserIdName string
	BeExposureItemIdName string

	// igraph
	IGraphName        string
	GroupName         string
	LabelName         string
	SaveOriginalField bool

	FieldMap map[string]string
	// redis, tablestore, featuredb
	FieldTypeMap map[string]constants.FSType

	// redis, featuredb
	Fields []string

	// hologres sequence tables
	HologresOnlineTableName  string
	HologresOfflineTableName string
	// tablestore sequence tables
	TableStoreOnlineTableName  string
	TableStoreOfflineTableName string
	// igraph sequence table
	IgraphEdgeName string

	// featuredb
	FeatureDBDatabaseName string
	FeatureDBSchemaName   string
	FeatureDBTableName    string
	FeatureDBSignature    string
}

type FeatureViewDao

type FeatureViewDao interface {
	GetFeatures(keys []interface{}, selectFields []string) ([]map[string]interface{}, error)
	GetUserSequenceFeature(keys []interface{}, userIdField string, sequenceConfig api.FeatureViewSeqConfig, onlineConfig []*api.SeqConfig) ([]map[string]interface{}, error)
}

func NewFeatureViewDao

func NewFeatureViewDao(config DaoConfig) FeatureViewDao

type FeatureViewFeatureDBDao

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

func NewFeatureViewFeatureDBDao

func NewFeatureViewFeatureDBDao(config DaoConfig) *FeatureViewFeatureDBDao

func (*FeatureViewFeatureDBDao) GetFeatures

func (d *FeatureViewFeatureDBDao) GetFeatures(keys []interface{}, selectFields []string) ([]map[string]interface{}, error)

func (*FeatureViewFeatureDBDao) GetUserSequenceFeature

func (d *FeatureViewFeatureDBDao) GetUserSequenceFeature(keys []interface{}, userIdField string, sequenceConfig api.FeatureViewSeqConfig, onlineConfig []*api.SeqConfig) ([]map[string]interface{}, error)

type FeatureViewHologresDao

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

func NewFeatureViewHologresDao

func NewFeatureViewHologresDao(config DaoConfig) *FeatureViewHologresDao

func (*FeatureViewHologresDao) GetFeatures

func (d *FeatureViewHologresDao) GetFeatures(keys []interface{}, selectFields []string) ([]map[string]interface{}, error)

func (*FeatureViewHologresDao) GetUserSequenceFeature

func (d *FeatureViewHologresDao) GetUserSequenceFeature(keys []interface{}, userIdField string, sequenceConfig api.FeatureViewSeqConfig, onlineConfig []*api.SeqConfig) ([]map[string]interface{}, error)

type FeatureViewIGraphDao

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

func NewFeatureViewIGraphDao

func NewFeatureViewIGraphDao(config DaoConfig) *FeatureViewIGraphDao

func (*FeatureViewIGraphDao) GetFeatures

func (d *FeatureViewIGraphDao) GetFeatures(keys []interface{}, selectFields []string) ([]map[string]interface{}, error)

func (*FeatureViewIGraphDao) GetUserSequenceFeature

func (d *FeatureViewIGraphDao) GetUserSequenceFeature(keys []interface{}, userIdField string, sequenceConfig api.FeatureViewSeqConfig, onlineConfig []*api.SeqConfig) ([]map[string]interface{}, error)

type FeatureViewMysqlDao

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

func NewFeatureViewMysqlDao

func NewFeatureViewMysqlDao(config DaoConfig) *FeatureViewMysqlDao

func (*FeatureViewMysqlDao) GetFeatures

func (d *FeatureViewMysqlDao) GetFeatures(keys []interface{}, selectFields []string) ([]map[string]interface{}, error)

func (*FeatureViewMysqlDao) GetUserSequenceFeature

func (d *FeatureViewMysqlDao) GetUserSequenceFeature(keys []interface{}, userIdField string, sequenceConfig api.FeatureViewSeqConfig, onlineConfig []*api.SeqConfig) ([]map[string]interface{}, error)

type FeatureViewRedisDao

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

func NewFeatureViewRedisDao

func NewFeatureViewRedisDao(config DaoConfig) *FeatureViewRedisDao

func (*FeatureViewRedisDao) GetFeatures

func (d *FeatureViewRedisDao) GetFeatures(keys []interface{}, selectFields []string) ([]map[string]interface{}, error)

func (*FeatureViewRedisDao) GetUserSequenceFeature

func (d *FeatureViewRedisDao) GetUserSequenceFeature(keys []interface{}, userIdField string, sequenceConfig api.FeatureViewSeqConfig, onlineConfig []*api.SeqConfig) ([]map[string]interface{}, error)

type FeatureViewTableStoreDao

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

func NewFeatureViewTableStoreDao

func NewFeatureViewTableStoreDao(config DaoConfig) *FeatureViewTableStoreDao

func (*FeatureViewTableStoreDao) GetFeatures

func (d *FeatureViewTableStoreDao) GetFeatures(keys []interface{}, selectFields []string) ([]map[string]interface{}, error)

func (*FeatureViewTableStoreDao) GetUserSequenceFeature

func (d *FeatureViewTableStoreDao) GetUserSequenceFeature(keys []interface{}, userIdField string, sequenceConfig api.FeatureViewSeqConfig, onlineConfig []*api.SeqConfig) ([]map[string]interface{}, error)