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: HbaseOnlineStoreConfig)[source]
Bases:
object
Hbase connecttion to connect to hbase.
- store_config
Online store config for Hbase store.
- property real_conn: Connection
Stores the real happybase Connection to connect to hbase.
- class feast.infra.online_stores.contrib.hbase_online_store.hbase.HbaseOnlineStore[source]
Bases:
OnlineStore
Online feature store for Hbase.
- _conn
Happybase Connection to connect to hbase thrift server.
- Type:
happybase.connection.Connection
- online_read(config: RepoConfig, table: FeatureView, entity_keys: List[EntityKey], requested_features: List[str] | None = None) List[Tuple[datetime | None, Dict[str, Value] | None]] [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: RepoConfig, table: FeatureView, data: List[Tuple[EntityKey, Dict[str, Value], datetime, datetime | None]], progress: Callable[[int], Any] | None) 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: RepoConfig, tables: Sequence[FeatureView], entities: Sequence[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: RepoConfig, tables_to_delete: Sequence[FeatureView], tables_to_keep: Sequence[FeatureView], entities_to_delete: Sequence[Entity], entities_to_keep: Sequence[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: typing_extensions.Literal[hbase] = 'hbase', host: str, port: str)[source]
Bases:
FeastConfigBaseModel
Online store config for Hbase store
- type: typing_extensions.Literal[hbase]
Online store type selector