Reads features values for the given entity keys. Args: config: The config for the current feature store. table: The feature view whose feature values should be read. entity_keys: The list of entity keys for which feature values should be read.
(
self,
config: RepoConfig,
table: FeatureView,
entity_keys: List[EntityKeyProto],
requested_features: Optional[List[str]] = None,
)
| 282 | |
| 283 | @abstractmethod |
| 284 | def online_read( |
| 285 | self, |
| 286 | config: RepoConfig, |
| 287 | table: FeatureView, |
| 288 | entity_keys: List[EntityKeyProto], |
| 289 | requested_features: Optional[List[str]] = None, |
| 290 | ) -> List[Tuple[Optional[datetime], Optional[Dict[str, ValueProto]]]]: |
| 291 | """ |
| 292 | Reads features values for the given entity keys. |
| 293 | |
| 294 | Args: |
| 295 | config: The config for the current feature store. |
| 296 | table: The feature view whose feature values should be read. |
| 297 | entity_keys: The list of entity keys for which feature values should be read. |
| 298 | requested_features: The list of features that should be read. |
| 299 | |
| 300 | Returns: |
| 301 | A list of the same length as entity_keys. Each item in the list is a tuple where the first |
| 302 | item is the event timestamp for the row, and the second item is a dict mapping feature names |
| 303 | to values, which are returned in proto format. |
| 304 | """ |
| 305 | pass |
| 306 | |
| 307 | @abstractmethod |
| 308 | def get_online_features( |
no outgoing calls
no test coverage detected