test

package

v0.37.1 Latest Latest Go to latest Published: Apr 17, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/feast-dev/feast

Links

Open Source Insights

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)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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 ¶ added in v0.22.0

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)

Source Files ¶

View all Source files

go_integration_test_utils.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL