feast

Documentation

Index

• type FeatureStore
  • func NewFeatureStore(config *registry.RepoConfig, callback transformation.TransformationCallback) (*FeatureStore, error)
  • func (fs *FeatureStore) DestructOnlineStore()
  • func (fs *FeatureStore) GetFcosMap() (map[string]*model.Entity, map[string]*model.FeatureView, ...)
  • func (fs *FeatureStore) GetFeatureService(name string) (*model.FeatureService, error)
  • func (fs *FeatureStore) GetFeatureView(featureViewName string, hideDummyEntity bool) (*model.FeatureView, error)
  • func (fs *FeatureStore) GetOnlineFeatures(ctx context.Context, featureRefs []string, ...) ([]*onlineserving.FeatureVector, error)
  • func (fs *FeatureStore) GetRepoConfig() *registry.RepoConfig
  • func (fs *FeatureStore) ListEntities(hideDummyEntity bool) ([]*model.Entity, error)
  • func (fs *FeatureStore) ListFeatureViews() ([]*model.FeatureView, error)
  • func (fs *FeatureStore) ListOnDemandFeatureViews() ([]*model.OnDemandFeatureView, error)
  • func (fs *FeatureStore) ListStreamFeatureViews() ([]*model.FeatureView, error)
  • func (fs *FeatureStore) ParseFeatures(kind interface{}) (*Features, error)
  • func (fs *FeatureStore) Registry() *registry.Registry
• type Features

Types

type FeatureStore

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

func NewFeatureStore

func NewFeatureStore(config *registry.RepoConfig, callback transformation.TransformationCallback) (*FeatureStore, error)

NewFeatureStore constructs a feature store fat client using the repo config (contents of feature_store.yaml converted to JSON map).

func (*FeatureStore) DestructOnlineStore

func (fs *FeatureStore) DestructOnlineStore()

func (*FeatureStore) GetFcosMap

func (fs *FeatureStore) GetFcosMap() (map[string]*model.Entity, map[string]*model.FeatureView, map[string]*model.OnDemandFeatureView, error)

func (*FeatureStore) GetFeatureService

func (fs *FeatureStore) GetFeatureService(name string) (*model.FeatureService, error)

func (*FeatureStore) GetFeatureView

func (fs *FeatureStore) GetFeatureView(featureViewName string, hideDummyEntity bool) (*model.FeatureView, error)

func (*FeatureStore) GetOnlineFeatures

func (fs *FeatureStore) GetOnlineFeatures(
	ctx context.Context,
	featureRefs []string,
	featureService *model.FeatureService,
	joinKeyToEntityValues map[string]*prototypes.RepeatedValue,
	requestData map[string]*prototypes.RepeatedValue,
	fullFeatureNames bool) ([]*onlineserving.FeatureVector, error)

TODO: Review all functions that use ODFV and Request FV since these have not been tested ToDo: Split GetOnlineFeatures interface into two: GetOnlinFeaturesByFeatureService and GetOnlineFeaturesByFeatureRefs

func (*FeatureStore) GetRepoConfig

func (fs *FeatureStore) GetRepoConfig() *registry.RepoConfig

func (*FeatureStore) ListEntities

func (fs *FeatureStore) ListEntities(hideDummyEntity bool) ([]*model.Entity, error)

func (*FeatureStore) ListFeatureViews

func (fs *FeatureStore) ListFeatureViews() ([]*model.FeatureView, error)

func (*FeatureStore) ListOnDemandFeatureViews

func (fs *FeatureStore) ListOnDemandFeatureViews() ([]*model.OnDemandFeatureView, error)

func (*FeatureStore) ListStreamFeatureViews

func (fs *FeatureStore) ListStreamFeatureViews() ([]*model.FeatureView, error)

func (*FeatureStore) ParseFeatures

func (fs *FeatureStore) ParseFeatures(kind interface{}) (*Features, error)

ParseFeatures parses the kind field of a GetOnlineFeaturesRequest protobuf message and populates a Features struct with the result.

func (*FeatureStore) Registry

func (fs *FeatureStore) Registry() *registry.Registry

type Features

type Features struct {
	FeaturesRefs   []string
	FeatureService *model.FeatureService
}

A Features struct specifies a list of features to be retrieved from the online store. These features can be specified either as a list of string feature references or as a feature service. String feature references must have format "feature_view:feature", e.g. "customer_fv:daily_transactions".