test

Documentation

Index

• func CleanUpInitializedRepo(basePath string)
• func CreateBaseFeatureView(name string, features []*model.Field, projection *model.FeatureViewProjection) *model.BaseFeatureView
• func CreateFeatureView(base *model.BaseFeatureView, ttl *durationpb.Duration, entities []string, ...) *model.FeatureView
• func CreateNewEntity(name string, joinKey string) *model.Entity
• func CreateNewFeatureService(name string, project string, createdTimestamp *timestamppb.Timestamp, ...) *model.FeatureService
• func CreateNewFeatureViewProjection(name string, nameAlias string, features []*model.Field, ...) *model.FeatureViewProjection
• func CreateNewField(name string, dtype types.ValueType_Enum) *model.Field
• func GetLatestFeatures(Rows []*Row, entities map[int64]bool) map[int64]*Row
• func GetProtoFromRecord(rec arrow.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 CleanUpInitializedRepo

func CleanUpInitializedRepo(basePath string)

func CreateBaseFeatureView

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

func CreateFeatureView

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

func CreateNewEntity

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

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.Field, joinKeyMap map[string]string) *model.FeatureViewProjection

func CreateNewField

func CreateNewField(name string, dtype types.ValueType_Enum) *model.Field

func GetLatestFeatures

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

func GetProtoFromRecord

func GetProtoFromRecord(rec arrow.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)