feast.infra.online_stores.contrib.hbase_online_store package

Submodules

feast.infra.online_stores.contrib.hbase_online_store.hbase module

class feast.infra.online_stores.contrib.hbase_online_store.hbase.HbaseConnection(store_config: feast.infra.online_stores.contrib.hbase_online_store.hbase.HbaseOnlineStoreConfig)[source]

Bases: object

Hbase connecttion to connect to hbase.

store_config

Online store config for Hbase store.

close() None[source]

Close the happybase connection.

property real_conn: happybase.connection.Connection

Stores the real happybase Connection to connect to hbase.

class feast.infra.online_stores.contrib.hbase_online_store.hbase.HbaseOnlineStore[source]

Bases: feast.infra.online_stores.online_store.OnlineStore

Online feature store for Hbase.

_conn

Happybase Connection to connect to hbase thrift server.

Type

happybase.connection.Connection

online_read(config: feast.repo_config.RepoConfig, table: feast.feature_view.FeatureView, entity_keys: List[feast.types.EntityKey_pb2.EntityKey], requested_features: Optional[List[str]] = None) List[Tuple[Optional[datetime.datetime], Optional[Dict[str, feast.types.Value_pb2.Value]]]][source]

Retrieve feature values from the Hbase online store.

Parameters
  • config – The RepoConfig for the current FeatureStore.

  • table – Feast FeatureView.

  • entity_keys – a list of entity keys that should be read from the FeatureStore.

  • requested_features – a list of requested feature names.

online_write_batch(config: feast.repo_config.RepoConfig, table: feast.feature_view.FeatureView, data: List[Tuple[feast.types.EntityKey_pb2.EntityKey, Dict[str, feast.types.Value_pb2.Value], datetime.datetime, Optional[datetime.datetime]]], progress: Optional[Callable[[int], Any]]) None[source]

Write a batch of feature rows to Hbase online store.

Parameters
  • config – The RepoConfig for the current FeatureStore.

  • table – Feast FeatureView.

  • data – a list of quadruplets containing Feature data. Each quadruplet contains an Entity Key,

  • values (a dict containing feature) –

  • row (an event timestamp for the) –

  • and

  • exists. (the created timestamp for the row if it) –

  • progress – Optional function to be called once every mini-batch of rows is written to

  • progress. (the online store. Can be used to display) –

teardown(config: feast.repo_config.RepoConfig, tables: Sequence[feast.feature_view.FeatureView], entities: Sequence[feast.entity.Entity])[source]

Delete tables from the Hbase Online Store.

Parameters
  • config – The RepoConfig for the current FeatureStore.

  • tables – Tables to delete from the feature repo.

update(config: feast.repo_config.RepoConfig, tables_to_delete: Sequence[feast.feature_view.FeatureView], tables_to_keep: Sequence[feast.feature_view.FeatureView], entities_to_delete: Sequence[feast.entity.Entity], entities_to_keep: Sequence[feast.entity.Entity], partial: bool)[source]

Update tables from the Hbase Online Store.

Parameters
  • config – The RepoConfig for the current FeatureStore.

  • tables_to_delete – Tables to delete from the Hbase Online Store.

  • tables_to_keep – Tables to keep in the Hbase Online Store.

class feast.infra.online_stores.contrib.hbase_online_store.hbase.HbaseOnlineStoreConfig(*, type: Literal['hbase'] = 'hbase', host: str, port: str)[source]

Bases: feast.repo_config.FeastConfigBaseModel

Online store config for Hbase store

host: str

Hostname of Hbase Thrift server

port: str

Port in which Hbase Thrift server is running

type: Literal['hbase']

Online store type selector

Module contents