test

Documentation

Index

• func CleanUpFile(absPath string) error
• func CleanUpInitializedRepo(basePath string)
• func CleanUpRepo(basePath string)
• func CreateBaseFeatureView(name string, features []*model.Feature, ...) *model.BaseFeatureView
• func CreateFeatureView(base *model.BaseFeatureView, ttl *durationpb.Duration, entities []string) *model.FeatureView
• func CreateNewEntity(name string, valueType types.ValueType_Enum, joinKey string) *model.Entity
• func CreateNewFeature(name string, dtype types.ValueType_Enum) *model.Feature
• func CreateNewFeatureService(name string, project string, createdTimestamp *timestamppb.Timestamp, ...) *model.FeatureService
• func CreateNewFeatureViewProjection(name string, nameAlias string, features []*model.Feature, ...) *model.FeatureViewProjection
• func GetLatestFeatures(Rows []*Row, entities map[int64]bool) map[int64]*Row
• func GetProtoFromRecord(rec array.Record) (map[string]*types.RepeatedValue, error)
• func SetupCleanFeatureRepo(basePath string) error
• func SetupInitializedRepo(basePath string) error
• type Row
  • func ReadParquet(filePath string) ([]*Row, error)

Functions

func CleanUpFile

func CleanUpFile(absPath string) error

func CleanUpInitializedRepo

func CleanUpInitializedRepo(basePath string)

func CleanUpRepo

func CleanUpRepo(basePath string)

func CreateBaseFeatureView

func CreateBaseFeatureView(name string, features []*model.Feature, projection *model.FeatureViewProjection) *model.BaseFeatureView

func CreateFeatureView

func CreateFeatureView(base *model.BaseFeatureView, ttl *durationpb.Duration, entities []string) *model.FeatureView

func CreateNewEntity

func CreateNewEntity(name string, valueType types.ValueType_Enum, joinKey string) *model.Entity

func CreateNewFeature

func CreateNewFeature(name string, dtype types.ValueType_Enum) *model.Feature

func CreateNewFeatureService

func CreateNewFeatureService(name string, project string, createdTimestamp *timestamppb.Timestamp, lastUpdatedTimestamp *timestamppb.Timestamp, projections []*model.FeatureViewProjection) *model.FeatureService

func CreateNewFeatureViewProjection

func CreateNewFeatureViewProjection(name string, nameAlias string, features []*model.Feature, joinKeyMap map[string]string) *model.FeatureViewProjection

func GetLatestFeatures

func GetLatestFeatures(Rows []*Row, entities map[int64]bool) map[int64]*Row

func GetProtoFromRecord

func GetProtoFromRecord(rec array.Record) (map[string]*types.RepeatedValue, error)

func SetupCleanFeatureRepo

func SetupCleanFeatureRepo(basePath string) error

func SetupInitializedRepo

func SetupInitializedRepo(basePath string) error

Types

type Row

type Row struct {
	EventTimestamp int64
	DriverId       int64
	ConvRate       float32
	AccRate        float32
	AvgDailyTrips  int32
	Created        int64
}

func ReadParquet

func ReadParquet(filePath string) ([]*Row, error)